17683908932 commented on issue #2251:
URL: https://github.com/apache/rocketmq/issues/2251#issuecomment-674553287
NettyRemotingAbstract.processResponseCommand()会向ResponseFuture里面添加response并且回调,
如果在这之前scanResponseTable已经移除了,
processResponseCommand()就不能向ResponseFuture里面添加response,
然后ChannelFutureListener会把ResponseFuture.setSendRequestOK设成true,
scanResponseTable再执行回调, response 是null, 但是sendRequestOK是true,
就会抛出这个异常MQClientException ex = new MQClientException("unknow reseaon",
responseFuture.getCause());
----------------------------------------------------------------
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:
[email protected]
