You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2021/11/30 13:12:17 UTC
[GitHub] [rocketmq] ShannonDing opened a new issue #3561: Consuming messages with namespace always failed in the example.
ShannonDing opened a new issue #3561:
URL: https://github.com/apache/rocketmq/issues/3561
see: [PushConsumerWithNamespace](https://github.com/apache/rocketmq/blob/master/example/src/main/java/org/apache/rocketmq/example/namespace/PushConsumerWithNamespace.java)
it always return RECONSUME_LATER in the listener.
```
defaultMQPushConsumer.registerMessageListener((MessageListenerConcurrently)(msgs, context) -> {
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;
});
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] yuz10 closed issue #3561: Consuming messages with namespace always failed in the example.
Posted by GitBox <gi...@apache.org>.
yuz10 closed issue #3561:
URL: https://github.com/apache/rocketmq/issues/3561
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] bcat4490 commented on issue #3561: Consuming messages with namespace always failed in the example.
Posted by GitBox <gi...@apache.org>.
bcat4490 commented on issue #3561:
URL: https://github.com/apache/rocketmq/issues/3561#issuecomment-984088752
@ShannonDing Can you assign this to me? Let me know, thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] ShannonDing commented on issue #3561: Consuming messages with namespace always failed in the example.
Posted by GitBox <gi...@apache.org>.
ShannonDing commented on issue #3561:
URL: https://github.com/apache/rocketmq/issues/3561#issuecomment-986380260
> @ShannonDing Can you assign this to me? Let me know, thanks.
yes, welcome.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] devfat commented on issue #3561: Consuming messages with namespace always failed in the example.
Posted by GitBox <gi...@apache.org>.
devfat commented on issue #3561:
URL: https://github.com/apache/rocketmq/issues/3561#issuecomment-1005017081
In my option, it return `ConsumeConcurrentlyStatus.CONSUME_SUCCESS` will not failed, or add `context.setDelayLevelWhenNextConsume`. however, the [commit#3884536c38e06742aec4c12d29a4f9e3e7c5ecbf](https://github.com/apache/rocketmq/commit/3884536c38e06742aec4c12d29a4f9e3e7c5ecbf#diff-b316776549ce0cba494ce6a426d6fdba78f81c6aac58a138246884930806ea72) indicate that the `ConsumeConcurrentlyStatus.RECONSUME_LATER` is especially.
What are the expected results in the example?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] bcat4490 commented on issue #3561: Consuming messages with namespace always failed in the example.
Posted by GitBox <gi...@apache.org>.
bcat4490 commented on issue #3561:
URL: https://github.com/apache/rocketmq/issues/3561#issuecomment-983254508
Can you assign this to me? Let me know, thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org