From f07bee564b11ee76fd065ec849a888bcf4e74e85 Mon Sep 17 00:00:00 2001 From: Jakob Odersky Date: Mon, 10 Sep 2018 15:10:09 -0700 Subject: Various message bus fixes (#212) 1. Move to pure mixin-based ("stackable traits") pattern. 2. Provide a "CreateOnDemand" mixin that ensures topics and subscriptions have been created before they are used. --- src/main/scala/xyz/driver/core/messaging/QueueBus.scala | 1 + 1 file changed, 1 insertion(+) (limited to 'src/main/scala/xyz/driver/core/messaging/QueueBus.scala') diff --git a/src/main/scala/xyz/driver/core/messaging/QueueBus.scala b/src/main/scala/xyz/driver/core/messaging/QueueBus.scala index d2ad073..45c9ed5 100644 --- a/src/main/scala/xyz/driver/core/messaging/QueueBus.scala +++ b/src/main/scala/xyz/driver/core/messaging/QueueBus.scala @@ -17,6 +17,7 @@ class QueueBus(implicit system: ActorSystem) extends Bus { override type SubscriptionConfig = Long override val defaultSubscriptionConfig: Long = 0 + override val executionContext = system.dispatcher override type MessageId = (String, SubscriptionConfig, Long) type Message[A] = BasicMessage[A] -- cgit v1.2.3