From 35eb380be21e76f2155e5efe6d2fb0b62d6e8f7e Mon Sep 17 00:00:00 2001 From: Hongcai Deng Date: Mon, 17 Sep 2018 15:24:11 +0800 Subject: [PATCH] feat: add send broker addr to ret --- lib/mq_client_api.js | 1 + 1 file changed, 1 insertion(+) diff --git a/lib/mq_client_api.js b/lib/mq_client_api.js index c3ae509..f70ce39 100644 --- a/lib/mq_client_api.js +++ b/lib/mq_client_api.js @@ -482,6 +482,7 @@ class MQClientAPI extends RemotingClient { const responseHeader = response.decodeCommandCustomHeader(); const messageQueue = new MessageQueue(msg.topic, brokerName, responseHeader.queueId); messageQueue.topic = this._clearProjectGroup(messageQueue.topic); + messageQueue.brokerAddr = brokerAddr; return { sendStatus,