fantow opened a new issue #2237:
URL: https://github.com/apache/rocketmq/issues/2237
BUG REPORT
Please describe the issue you observed:
What did you do (The steps to reproduce)?
**In the class NettyRemotingAbstract,there is a method to process the
timeout ResponseFuture in responseTable named scanResponseTable().
Now,this method's processing steps are:
1.scan the responseTable and find the responseFuture which are not
timeout.
2.remove this responseFuture which in responseTable and put them in a
new List named rfList
3.then we will scan rfList and execute them callback function which are
timeout.
I think the logic is wrong.
1.Is it a necessory process that we should execute the callback function
which are timeout?
2.From the method name and annotation,this method is used to scan and
expire deprecated request,it should choose the timeout ResponseFuture and
remove it.**
What did you expect to see?
What did you see instead?
Please tell us about your environment:
JDK 1.8
RocketMQ 4.7.1
Other information (e.g. detailed explanation, logs, related issues,
suggestions how to fix, etc):
**May I submit a PR to fix it?**
----------------------------------------------------------------
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]
