diff options
author | Justin Tan <justin@driver.xyz> | 2018-09-05 21:37:51 +0800 |
---|---|---|
committer | Justin Tan <justin@driver.xyz> | 2018-09-05 21:37:51 +0800 |
commit | 2fe394cb03dac224d31f6ab709af8b06f89e7752 (patch) | |
tree | 18e6bc1ecbc8714f549c6f91cbadf45b921f621f | |
parent | 9083026ac05b0674c9e235ce3efba8990fdabce7 (diff) | |
download | driver-core-2fe394cb03dac224d31f6ab709af8b06f89e7752.tar.gz driver-core-2fe394cb03dac224d31f6ab709af8b06f89e7752.tar.bz2 driver-core-2fe394cb03dac224d31f6ab709af8b06f89e7752.zip |
print logsjustin/debug
-rw-r--r-- | src/main/scala/xyz/driver/core/messaging/AliyunBus.scala | 6 |
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] |