Various message bus fixes (#212)v1.14.0

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.

1 files changed, 3 insertions, 3 deletions

diff --git a/src/main/scala/xyz/driver/core/messaging/AliyunBus.scala b/src/main/scala/xyz/driver/core/messaging/AliyunBus.scala
index 27e66f6..92e47bd 100644
--- a/src/main/scala/xyz/driver/core/messaging/AliyunBus.scala
+++ b/src/main/scala/xyz/driver/core/messaging/AliyunBus.scala
@@ -17,7 +17,7 @@ class AliyunBus(
     region: String,
     namespace: String,
     pullTimeout: Int)(implicit val executionContext: ExecutionContext)
-    extends Bus with StreamBus with CreateBeforeStream {
+    extends Bus {
   val endpoint     = s"https://$accountId.mns.$region.aliyuncs.com"
   val cloudAccount = new CloudAccount(accessId, accessSecret, endpoint)
   val client       = cloudAccount.getMNSClient
@@ -115,7 +115,7 @@ class AliyunBus(
     Future.sequence(publishMessages).map(_ => ())
   }
 
-  override def createTopic(topic: Topic[_]): Future[Unit] = Future {
+  def createTopic(topic: Topic[_]): Future[Unit] = Future {
     val topicName   = rawTopicName(topic)
     val topicExists = Option(client.listTopic(topicName, "", 1)).exists(!_.getResult.isEmpty)
     if (!topicExists) {
@@ -125,7 +125,7 @@ class AliyunBus(
     }
   }
 
-  override def createSubscription(topic: Topic[_], config: SubscriptionConfig): Future[Unit] = Future {
+  def createSubscription(topic: Topic[_], config: SubscriptionConfig): Future[Unit] = Future {
     val subscriptionName = rawSubscriptionName(config, topic)
     val topicName        = rawTopicName(topic)
     val topicRef         = client.getTopicRef(topicName)