From 502ca6041e1d43906f01e2a9f5b34e77080a02f7 Mon Sep 17 00:00:00 2001 From: zhangxu16 Date: Thu, 16 Sep 2021 13:48:06 +0800 Subject: [PATCH] fix ci --- .../apache/rocketmq/broker/processor/SendMessageProcessor.java | 1 + 1 file changed, 1 insertion(+) diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java index 19a4f533..950c0935 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java @@ -189,6 +189,7 @@ public class SendMessageProcessor extends AbstractSendMessageProcessor implement topicConfig = this.brokerController.getTopicConfigManager().createTopicInSendMessageBackMethod(newTopic, DLQ_NUMS_PER_GROUP, PermName.PERM_WRITE | PermName.PERM_READ, 0); + if (null == topicConfig) { response.setCode(ResponseCode.SYSTEM_ERROR); response.setRemark("topic[" + newTopic + "] not exist"); -- GitLab