aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJustin Tan <justin@driver.xyz>2018-09-05 21:37:51 +0800
committerJustin Tan <justin@driver.xyz>2018-09-05 21:37:51 +0800
commit2fe394cb03dac224d31f6ab709af8b06f89e7752 (patch)
tree18e6bc1ecbc8714f549c6f91cbadf45b921f621f
parent9083026ac05b0674c9e235ce3efba8990fdabce7 (diff)
downloaddriver-core-justin/debug.tar.gz
driver-core-justin/debug.tar.bz2
driver-core-justin/debug.zip
print logsjustin/debug
-rw-r--r--src/main/scala/xyz/driver/core/messaging/AliyunBus.scala6
1 files changed, 6 insertions, 0 deletions
diff --git a/src/main/scala/xyz/driver/core/messaging/AliyunBus.scala b/src/main/scala/xyz/driver/core/messaging/AliyunBus.scala
index 66ae377..2fa30f1 100644
--- a/src/main/scala/xyz/driver/core/messaging/AliyunBus.scala
+++ b/src/main/scala/xyz/driver/core/messaging/AliyunBus.scala
@@ -88,8 +88,14 @@ class AliyunBus(
}
override def publishMessages[A](topic: Topic[A], messages: Seq[A]): Future[Unit] = {
+
+ System.err.println("--------------------")
+ System.err.println(rawTopicName(topic))
+ System.err.println("--------------------")
+
val topicRef = client.getTopicRef(rawTopicName(topic))
+
val publishMessages = messages.map { message =>
val promise = Promise[TopicMessage]