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