Add client version check

apache · Sep 8, 2023 · b33c915 · b33c915
1 parent 65412b0
commit b33c915
Showing 1 changed file with 8 additions and 5 deletions.
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
@@ -44,6 +44,7 @@
 import java.util.function.Consumer;
 import javax.annotation.Nullable;
 import org.apache.rocketmq.common.AbortProcessException;
+import org.apache.rocketmq.common.MQVersion;
 import org.apache.rocketmq.common.Pair;
 import org.apache.rocketmq.common.ServiceThread;
 import org.apache.rocketmq.common.UtilAll;
@@ -269,11 +270,13 @@ public void processRequestCommand(final ChannelHandlerContext ctx, final Remotin
         Runnable run = buildProcessRequestHandler(ctx, cmd, pair, opaque);
 
         if (isShuttingDown.get()) {
-            final RemotingCommand response = RemotingCommand.createResponseCommand(ResponseCode.GO_AWAY,
-                "please go away");
-            response.setOpaque(opaque);
-            writeResponse(ctx.channel(), cmd, response);
-            return;
+            if (cmd.getVersion() > MQVersion.Version.V5_1_3.ordinal()) {
+                final RemotingCommand response = RemotingCommand.createResponseCommand(ResponseCode.GO_AWAY,
+                    "please go away");
+                response.setOpaque(opaque);
+                writeResponse(ctx.channel(), cmd, response);
+                return;
+            }
         }
 
         if (pair.getObject1().rejectRequest()) {