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

[yu...@apache.org]

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 <32...@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();