Skip to content

Commit a918020

Browse files
authored
Fix the issue of sending message "No route information of this topic: xxx" when the producer does not configure the namespace
1 parent 1984e07 commit a918020

File tree

1 file changed

+7
-3
lines changed

1 file changed

+7
-3
lines changed

rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/autoconfigure/RocketMQAutoConfiguration.java

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -115,7 +115,9 @@ public DefaultMQProducer defaultMQProducer(RocketMQProperties rocketMQProperties
115115
producer.setCompressMsgBodyOverHowmuch(producerConfig.getCompressMessageBodyThreshold());
116116
producer.setRetryAnotherBrokerWhenNotStoreOK(producerConfig.isRetryNextServer());
117117
producer.setUseTLS(producerConfig.isTlsEnable());
118-
producer.setNamespace(producerConfig.getNamespace());
118+
if (StringUtils.hasText(producerConfig.getNamespace())) {
119+
producer.setNamespace(producerConfig.getNamespace());
120+
}
119121
producer.setInstanceName(producerConfig.getInstanceName());
120122
log.info("a producer ({}) init on namesrv {}", groupName, nameServer);
121123
return producer;
@@ -147,7 +149,9 @@ public DefaultLitePullConsumer defaultLitePullConsumer(RocketMQProperties rocket
147149
groupName, topicName, messageModel, selectorType, selectorExpression, ak, sk, pullBatchSize, useTLS);
148150
litePullConsumer.setEnableMsgTrace(consumerConfig.isEnableMsgTrace());
149151
litePullConsumer.setCustomizedTraceTopic(consumerConfig.getCustomizedTraceTopic());
150-
litePullConsumer.setNamespace(consumerConfig.getNamespace());
152+
if (StringUtils.hasText(consumerConfig.getNamespace())) {
153+
litePullConsumer.setNamespace(consumerConfig.getNamespace());
154+
}
151155
litePullConsumer.setInstanceName(consumerConfig.getInstanceName());
152156
log.info("a pull consumer({} sub {}) init on namesrv {}", groupName, topicName, nameServer);
153157
return litePullConsumer;
@@ -182,4 +186,4 @@ static class DefaultMQProducerExistsCondition {
182186
static class DefaultLitePullConsumerExistsCondition {
183187
}
184188
}
185-
}
189+
}

0 commit comments

Comments
 (0)