(rocketmq-spring) branch master updated: Modify the judgment method (#752)

[jinrongtong]

This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-spring.git


The following commit(s) were added to refs/heads/master by this push:
     new bddc554  Modify the judgment method (#752)
bddc554 is described below

commit bddc5547f103699194529829d11f148785b09a87
Author: panzhi <panzh...@qq.com>
AuthorDate: Tue Dec 2 11:51:17 2025 +0800

    Modify the judgment method (#752)
---
 .../rocketmq/spring/support/DefaultRocketMQListenerContainer.java   | 6 +++---
 .../apache/rocketmq/client/support/DefaultListenerContainer.java    | 6 +++---
 2 files changed, 6 insertions(+), 6 deletions(-)

diff --git 
a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/DefaultRocketMQListenerContainer.java
 
b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/DefaultRocketMQListenerContainer.java
index c3bf81b..5f16fc2 100644
--- 
a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/DefaultRocketMQListenerContainer.java
+++ 
b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/DefaultRocketMQListenerContainer.java
@@ -625,9 +625,9 @@ public class DefaultRocketMQListenerContainer implements 
InitializingBean,
         if (rocketMQListener == null && rocketMQReplyListener == null) {
             throw new IllegalArgumentException("Property 'rocketMQListener' or 
'rocketMQReplyListener' is required");
         }
-        Assert.notNull(consumerGroup, "Property 'consumerGroup' is required");
-        Assert.notNull(nameServer, "Property 'nameServer' is required");
-        Assert.notNull(topic, "Property 'topic' is required");
+        Assert.hasText(consumerGroup, "Property 'consumerGroup' is required");
+        Assert.hasText(nameServer, "Property 'nameServer' is required");
+        Assert.hasText(topic, "Property 'topic' is required");
 
         RPCHook rpcHook = 
RocketMQUtil.getRPCHookByAkSk(applicationContext.getEnvironment(),
             this.rocketMQMessageListener.accessKey(), 
this.rocketMQMessageListener.secretKey());
diff --git 
a/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/support/DefaultListenerContainer.java
 
b/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/support/DefaultListenerContainer.java
index 48151cd..cf77d2d 100644
--- 
a/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/support/DefaultListenerContainer.java
+++ 
b/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/support/DefaultListenerContainer.java
@@ -255,9 +255,9 @@ public class DefaultListenerContainer implements 
InitializingBean,
         if (rocketMQListener == null) {
             throw new IllegalArgumentException("Property 'rocketMQListener' is 
required");
         }
-        Assert.notNull(consumerGroup, "Property 'consumerGroup' is required");
-        Assert.notNull(topic, "Property 'topic' is required");
-        Assert.notNull(tag, "Property 'tag' is required");
+        Assert.hasText(consumerGroup, "Property 'consumerGroup' is required");
+        Assert.hasText(topic, "Property 'topic' is required");
+        Assert.hasText(tag, "Property 'tag' is required");
         FilterExpression filterExpression = null;
         final ClientServiceProvider provider = 
ClientServiceProvider.loadService();
         if (StringUtils.hasLength(this.getTag())) {