From 39fac5ae098cb1f891d63eec461c6e757231dd63 Mon Sep 17 00:00:00 2001
From: H145608 <1404499274@qq.com>
Date: Wed, 20 May 2026 12:15:00 +0800
Subject: [PATCH] [ISSUE #10247] Remove duplicate remove call in
 InvocationChannel

Remove redundant second inFlightRequestMap.remove() call in writeAndFlush().
The remove was already called once at line 41 to retrieve the context.
The duplicate remove at line 46 had no effect and was unnecessary.

Fixes: #10247
---
 .../apache/rocketmq/proxy/service/channel/InvocationChannel.java | 1 -
 1 file changed, 1 deletion(-)

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);
     }