[ISSUE #3561] Optimize consuming messages with namespace example

Co-authored-by: yangmingxu <mingxu914>
apache · Mar 8, 2022 · febc083 · febc083
1 parent 7a5d937
commit febc083
Showing 1 changed file with 1 addition and 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
@@ -29,7 +29,7 @@ public static void main(String[] args) throws Exception {
             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();