From 2fe394cb03dac224d31f6ab709af8b06f89e7752 Mon Sep 17 00:00:00 2001 From: Justin Tan Date: Wed, 5 Sep 2018 21:37:51 +0800 Subject: print logs --- src/main/scala/xyz/driver/core/messaging/AliyunBus.scala | 6 ++++++ 1 file changed, 6 insertions(+) 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] -- cgit v1.2.3