Skip to content

Commit b97f60f

Browse files
committed
[ISSUE apache#8963] Fix code36 request sent to ns
1 parent 9202de3 commit b97f60f

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java

+3
Original file line numberDiff line numberDiff line change
@@ -767,6 +767,9 @@ private void sendMessageBack(MessageExt msg, int delayLevel, final String broker
767767
} else {
768768
String brokerAddr = (null != brokerName) ? this.mQClientFactory.findBrokerAddressInPublish(brokerName)
769769
: RemotingHelper.parseSocketAddressAddr(msg.getStoreHost());
770+
if (UtilAll.isBlank(brokerAddr)) {
771+
throw new MQClientException("Broker[" + brokerName + "] master node does not exist", null);
772+
}
770773
this.mQClientFactory.getMQClientAPIImpl().consumerSendMessageBack(brokerAddr, brokerName, msg,
771774
this.defaultMQPushConsumer.getConsumerGroup(), delayLevel, 5000, getMaxReconsumeTimes());
772775
}

0 commit comments

Comments
 (0)