[rocketmq] branch develop updated: [ISSUE #7111] Remove responseFuture from the responseTable when exception occurs (#7112)

[lizhimin]

This is an automated email from the ASF dual-hosted git repository.

lizhimin pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new bd0e9c09db [ISSUE #7111] Remove responseFuture from the responseTable 
when exception occurs (#7112)
bd0e9c09db is described below

commit bd0e9c09db9748f7f74a0c707579142dccf30afc
Author: PiteXChen <44110731+rappe...@users.noreply.github.com>
AuthorDate: Tue Aug 29 19:39:27 2023 +0800

    [ISSUE #7111] Remove responseFuture from the responseTable when exception 
occurs (#7112)
    
    * remove responseFuture when exception
    * Empty-Commit
    
    ---------
    Co-authored-by: chenyong152 <chenyong...@midea.com>
---
 .../java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java
 
b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java
index 44d6a3df4c..fce2de267f 100644
--- 
a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java
+++ 
b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java
@@ -529,6 +529,7 @@ public abstract class NettyRemotingAbstract {
                     log.warn("send a request command to channel <{}> failed.", 
RemotingHelper.parseChannelRemoteAddr(channel));
                 });
             } catch (Exception e) {
+                responseTable.remove(opaque);
                 responseFuture.release();
                 log.warn("send a request command to channel <" + 
RemotingHelper.parseChannelRemoteAddr(channel) + "> Exception", e);
                 throw new 
RemotingSendRequestException(RemotingHelper.parseChannelRemoteAddr(channel), e);