aboutsummaryrefslogtreecommitdiff
path: root/src/main/scala/xyz/driver/core/messaging/StreamBus.scala
Commit message (Collapse)AuthorAgeFilesLines
* Move storage and messaging to separate projectsJakob Odersky2018-10-091-102/+0
|
* Fixes for Alicloud pubsub (#230)Zach Smith2018-10-021-1/+1
| | | | | | * Remove recover from processMessage in StreatBus * Check if queue exists before creating
* RFC Add basicSubscribeWithRestart helper method to StreamBus (#214)Zach Smith2018-09-121-1/+43
| | | | | | | | | | * Add basicSubscribeWithRestart helper method to StreamBus * Include helper for subscribe with Flow * PR comments * Rename methods, call run
* Various message bus fixes (#212)v1.14.0Jakob Odersky2018-09-101-6/+7
| | | | | 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.
* Add message bus and topic abstractions (#181)v1.12.0Jakob Odersky2018-07-311-0/+59