Open
Description
Before Creating the Bug Report
I found a bug, not just asking a question, which should be created in GitHub Discussions.
I have searched the GitHub Issues and GitHub Discussions of this repository and believe that this is not a duplicate.
I have confirmed that this bug belongs to the current repository, not other repositories of RocketMQ.
Runtime platform environment
win11
RocketMQ version
5.3.1
JDK Version
1.8
Describe the Bug
调用sendAndReceive()时,报org.springframework.messaging.MessagingException: CODE: 10006.
原因是5.3.1中添加了如下代码引发 requestResponseFuture.acquireCountDownLatch();
Caused by: org.springframework.messaging.MessagingException: CODE: 10006 DESC: send request message to <dms__process_edit_after__contract> OK, but wait reply message timeout, 10000 ms.; nested exception is org.apache.rocketmq.client.exception.RequestTimeoutException: CODE: 10006 DESC: send request message to <dms__process_edit_after__contract> OK, but wait reply message timeout, 10000 ms.
at org.apache.rocketmq.spring.core.RocketMQTemplate.sendAndReceive(RocketMQTemplate.java:253) ~[rocketmq-spring-boot-2.3.3.jar:2.3.3]
at org.apache.rocketmq.spring.core.RocketMQTemplate.sendAndReceive(RocketMQTemplate.java:269) ~[rocketmq-spring-boot-2.3.3.jar:2.3.3]
at org.apache.rocketmq.spring.core.RocketMQTemplate.sendAndReceive(RocketMQTemplate.java:150) ~[rocketmq-spring-boot-2.3.3.jar:2.3.3]
at com.desuo.dms.service.mq.RocketMQService.sendAndReceive(RocketMQService.java:32) ~[classes/:na]
... 135 common frames omitted
Caused by: org.apache.rocketmq.client.exception.RequestTimeoutException: CODE: 10006 DESC: send request message to <dms__process_edit_after__contract> OK, but wait reply message timeout, 10000 ms.
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.waitResponse(DefaultMQProducerImpl.java:1721) ~[rocketmq-client-5.3.1.jar:5.3.1]
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.request(DefaultMQProducerImpl.java:1593) ~[rocketmq-client-5.3.1.jar:5.3.1]
at org.apache.rocketmq.client.producer.DefaultMQProducer.request(DefaultMQProducer.java:794) ~[rocketmq-client-5.3.1.jar:5.3.1]
at org.apache.rocketmq.spring.core.RocketMQTemplate.sendAndReceive(RocketMQTemplate.java:246) ~[rocketmq-spring-boot-2.3.3.jar:2.3.3]
... 138 common frames omitted
Steps to Reproduce
/
What Did You Expect to See?
/
What Did You See Instead?
/
Additional Context
No response
Activity