blob: 8dd0776134828451044f6552fb10627885a16644 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
|
package xyz.driver.core.messaging
import akka.actor.ActorSystem
import org.scalatest.FlatSpec
import org.scalatest.concurrent.ScalaFutures
import scala.concurrent.ExecutionContext
import scala.concurrent.duration._
class QueueBusTest extends FlatSpec with ScalaFutures {
implicit val patience: PatienceConfig = PatienceConfig(timeout = 10.seconds)
def busBehaviour(bus: Bus)(implicit ec: ExecutionContext): Unit = {
it should "deliver messages to a subscriber" in {
val topic = Topic.string("test.topic1")
bus.fetchMessages(topic).futureValue
bus.publishMessages(topic, Seq("hello world!"))
Thread.sleep(100)
val messages = bus.fetchMessages(topic)
assert(messages.futureValue.map(_.data).toList == List("hello world!"))
}
}
implicit val system: ActorSystem = ActorSystem("queue-test")
import system.dispatcher
"A queue-based bus" should behave like busBehaviour(new QueueBus)
}
|