(rocketmq) branch develop updated: [ISSUE #9203] Replace numbers with static variables defined in RequestCode

[jinrongtong]

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

jinrongtong 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 f2d4e0d7b3 [ISSUE #9203] Replace numbers with static variables defined 
in RequestCode
f2d4e0d7b3 is described below

commit f2d4e0d7b33bec661f3b55e40fb774f042dc98ea
Author: 阿洋 <xinzhuxiansh...@126.com>
AuthorDate: Tue Feb 25 08:09:53 2025 +0800

    [ISSUE #9203] Replace numbers with static variables defined in RequestCode
---
 .../java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java
 
b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java
index e92809ccdf..92ced6b01a 100644
--- 
a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java
+++ 
b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java
@@ -87,6 +87,7 @@ import 
org.apache.rocketmq.remoting.exception.RemotingSendRequestException;
 import org.apache.rocketmq.remoting.exception.RemotingTimeoutException;
 import org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException;
 import org.apache.rocketmq.remoting.protocol.RemotingCommand;
+import org.apache.rocketmq.remoting.protocol.RequestCode;
 import org.apache.rocketmq.remoting.protocol.ResponseCode;
 import org.apache.rocketmq.remoting.proxy.SocksProxyConfig;
 
@@ -604,7 +605,7 @@ public class NettyRemotingClient extends 
NettyRemotingAbstract implements Remoti
             }
             String remoteAddr = 
RemotingHelper.parseChannelRemoteAddr(responseFuture.getChannel());
             // interrupt only pull message request
-            if (brokerAddrSet.contains(remoteAddr) && (cmd.getCode() == 11 || 
cmd.getCode() == 361)) {
+            if (brokerAddrSet.contains(remoteAddr) && (cmd.getCode() == 
RequestCode.PULL_MESSAGE || cmd.getCode() == RequestCode.LITE_PULL_MESSAGE)) {
                 LOGGER.info("interrupt {}", cmd);
                 responseFuture.interrupt();
             }