[rocketmq] branch develop updated: [ISSUE #3561] Optimize consuming messages with namespace example

[yuzhou]

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

yuzhou pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new febc083  [ISSUE #3561] Optimize consuming messages with namespace 
example
febc083 is described below

commit febc083605f127fafb281faaee9bd555008874b8
Author: ymingxu <32387653+ymin...@users.noreply.github.com>
AuthorDate: Tue Mar 8 16:26:33 2022 +0800

    [ISSUE #3561] Optimize consuming messages with namespace example
    
    Co-authored-by: yangmingxu <mingxu914>
---
 .../apache/rocketmq/example/namespace/PushConsumerWithNamespace.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/example/src/main/java/org/apache/rocketmq/example/namespace/PushConsumerWithNamespace.java
 
b/example/src/main/java/org/apache/rocketmq/example/namespace/PushConsumerWithNamespace.java
index a0fdeef..40f1db2 100644
--- 
a/example/src/main/java/org/apache/rocketmq/example/namespace/PushConsumerWithNamespace.java
+++ 
b/example/src/main/java/org/apache/rocketmq/example/namespace/PushConsumerWithNamespace.java
@@ -29,7 +29,7 @@ public class PushConsumerWithNamespace {
             msgs.stream().forEach((msg) -> {
                 System.out.printf("Msg topic is:%s, MsgId is:%s, 
reconsumeTimes is:%s%n", msg.getTopic() , msg.getMsgId(), 
msg.getReconsumeTimes());
             });
-            return ConsumeConcurrentlyStatus.RECONSUME_LATER;
+            return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
         });
 
         defaultMQPushConsumer.start();