mirror of
https://github.com/apache/rocketmq.git
synced 2026-08-28 20:09:14 +08:00
[ISSUE #3561] Optimize consuming messages with namespace example
Co-authored-by: yangmingxu <mingxu914>
This commit is contained in:
+1
-1
@@ -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();
|
||||
|
||||
Reference in New Issue
Block a user