Fix the issue of sending message "No route information of this topic: xxx" when the producer does not configure the namespace
diff --git a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/autoconfigure/RocketMQAutoConfiguration.java b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/autoconfigure/RocketMQAutoConfiguration.java
index 9ed8ad9..1bf9764 100644
--- a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/autoconfigure/RocketMQAutoConfiguration.java
+++ b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/autoconfigure/RocketMQAutoConfiguration.java
@@ -115,7 +115,9 @@
producer.setCompressMsgBodyOverHowmuch(producerConfig.getCompressMessageBodyThreshold());
producer.setRetryAnotherBrokerWhenNotStoreOK(producerConfig.isRetryNextServer());
producer.setUseTLS(producerConfig.isTlsEnable());
- producer.setNamespace(producerConfig.getNamespace());
+ if (StringUtils.hasText(producerConfig.getNamespace())) {
+ producer.setNamespace(producerConfig.getNamespace());
+ }
producer.setInstanceName(producerConfig.getInstanceName());
log.info("a producer ({}) init on namesrv {}", groupName, nameServer);
return producer;
@@ -147,7 +149,9 @@
groupName, topicName, messageModel, selectorType, selectorExpression, ak, sk, pullBatchSize, useTLS);
litePullConsumer.setEnableMsgTrace(consumerConfig.isEnableMsgTrace());
litePullConsumer.setCustomizedTraceTopic(consumerConfig.getCustomizedTraceTopic());
- litePullConsumer.setNamespace(consumerConfig.getNamespace());
+ if (StringUtils.hasText(consumerConfig.getNamespace())) {
+ litePullConsumer.setNamespace(consumerConfig.getNamespace());
+ }
litePullConsumer.setInstanceName(consumerConfig.getInstanceName());
log.info("a pull consumer({} sub {}) init on namesrv {}", groupName, topicName, nameServer);
return litePullConsumer;
@@ -182,4 +186,4 @@
static class DefaultLitePullConsumerExistsCondition {
}
}
-}
\ No newline at end of file
+}
