diff options
Diffstat (limited to 'src/main/scala/xyz/driver/core/messaging/QueueBus.scala')
| -rw-r--r-- | src/main/scala/xyz/driver/core/messaging/QueueBus.scala | 1 |
1 files changed, 1 insertions, 0 deletions
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] |