From 6b98673a0b1bdd77ec0d062f9ac92efa7dd39cc7 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 894d121..895ee19 100644 --- a/lib/mq_client_api.js +++ b/lib/mq_client_api.js @@ -491,6 +491,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,