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 2020/01/19 03:48:39 UTC
[GitHub] [rocketmq] 2259289435 removed a comment on issue #1727: **BUG
REPORT**ReqResp timeout execute N time
2259289435 removed a comment on issue #1727: **BUG REPORT**ReqResp timeout execute N time
URL: https://github.com/apache/rocketmq/issues/1727#issuecomment-575964019
Could you give more detail how to reproduce it ?
1.producer.request(requestMessage, new RequestCallback() {
@Override
public void onSuccess(Message message) {
log.info("reply body : {}", new String(message.getBody()));
}
@Override
public void onException(Throwable e) {
log.error("request error : {}, correlationId : {}", requestMessage.getProperty(MessageConst.PROPERTY_CORRELATION_ID), e.getMessage());
}
}, 3000L);
2.on timeout,onException execute 2 times。
producer.impl have timer ,producer.impl.instance.defaultmqproducer.impl have timer.
What do you mean change timer to static ?
try to fixbug
![image](https://user-images.githubusercontent.com/23507198/72674429-4afdf080-3ab1-11ea-831d-04851c200e7d.png)
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
With regards,
Apache Git Services