diff --git a/proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/InvocationChannel.java b/proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/InvocationChannel.java index 00e8cea99c9..bbaaddd293e 100644 --- a/proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/InvocationChannel.java +++ b/proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/InvocationChannel.java @@ -41,7 +41,6 @@ public ChannelFuture writeAndFlush(Object msg) { if (null != context) { context.handle(responseCommand); } - inFlightRequestMap.remove(responseCommand.getOpaque()); } return super.writeAndFlush(msg); }