search

apache / rocketmq

Apache RocketMQ is a cloud native messaging and streaming platform, making it simple to build event-driven applications.
https://rocketmq.apache.org/
Apache License 2.0
21.19k stars 11.67k forks source link

request-reply return sended message #6166

Closed 1024cainiao closed 1 year ago

1024cainiao commented 1 year ago

env: rocketmq-client:4.9.4

question: use org.apache.rocketmq.client.producer.DefaultMQProducer#request(org.apache.rocketmq.common.message.Message, long) Unable to receive the message returned by the consumer, And received a message from producer. Find by the source code, image The code in the red box is wrong.

Request overloaded method in the same class, Only the following are available. org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl#request(org.apache.rocketmq.common.message.Message, org.apache.rocketmq.client.producer.MessageQueueSelector, java.lang.Object, org.apache.rocketmq.client.producer.RequestCallback, long) image

Oliverwqcwrw commented 1 year ago

Hello @1024cainiao , PR #4896 fixed this issue