How does rocketmq return the message to the specified queue when the message is retried?

[ZShUn]

Search before creation

• I had searched in the issues and found no similar issues.

Documentation Related

When I used queue to implement traffic isolation, I found that the message retry queue was single and could not return to the consumption queue.

Are you willing to submit PR?

• Yes I am willing to submit a PR!

[humkum]

Retry messages are only sent to the retry queue of the broker where the message is located. You cannot specify a queue for sending.

[ZShUn]

I don't know why it is designed this way. If you need to implement traffic isolation, it will be difficult to control during the retry phase.

[ZShUn]

If I use Agent to rewrite the result during retry, will it have any effect? ​​For example, rewrite ConsumeMessageConcurrentlyService.this.processConsumeResult(status, context, this); status parameter from RECONSUME_LATER to CONSUME_SUCCESS. Then I implement the retry with different traffic myself, so that RocketMQ internal consumption will be judged as successful?