diff --git a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/autoconfigure/ListenerContainerConfiguration.java b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/autoconfigure/ListenerContainerConfiguration.java index 5bd64136..7544b200 100644 --- a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/autoconfigure/ListenerContainerConfiguration.java +++ b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/autoconfigure/ListenerContainerConfiguration.java @@ -155,6 +155,11 @@ private DefaultRocketMQListenerContainer createRocketMQListenerContainer(String container.setMessageConverter(rocketMQMessageConverter.getMessageConverter()); container.setName(name); + // set default namespace + String namespace = rocketMQProperties.getConsumer().getNamespace(); + if (StringUtils.isEmpty(container.getNamespace()) && !StringUtils.isEmpty(namespace)) { + container.setNamespace(namespace); + } return container; }