解决remoting层报超时的问题

mhcxp · Apr 8, 2015 · 2e3397e · 2e3397e
1 parent 6de88b8
commit 2e3397e
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...tmq-remoting/src/main/java/com/alibaba/rocketmq/remoting/netty/NettyRemotingAbstract.java b/...tmq-remoting/src/main/java/com/alibaba/rocketmq/remoting/netty/NettyRemotingAbstract.java
@@ -247,8 +247,8 @@ public void processResponseCommand(ChannelHandlerContext ctx, RemotingCommand cm
         final ResponseFuture responseFuture = responseTable.get(cmd.getOpaque());
         if (responseFuture != null) {
             responseFuture.setResponseCommand(cmd);
-
             responseFuture.release();
+            responseTable.remove(cmd.getOpaque());
 
             if (responseFuture.getInvokeCallback() != null) {
                 boolean runInThisThread = false;
@@ -295,7 +295,6 @@ public void run() {
             plog.warn(cmd.toString());
         }
 
-        responseTable.remove(cmd.getOpaque());
     }