Modify the judgment method

Author: panzhi33

rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/DefaultRocketMQListenerContainer.java

@@ -625,9 +625,9 @@ private void initRocketMQPushConsumer() throws MQClientException {
         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());

rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/support/DefaultListenerContainer.java

@@ -255,9 +255,9 @@ private void initRocketMQPushConsumer() {
         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())) {