Commit 8ea4d2c 1 parent 14156b4 commit 8ea4d2c Copy full SHA for 8ea4d2c
File tree 1 file changed +2
-1
lines changed
remoting/src/main/java/org/apache/rocketmq/remoting/netty
1 file changed +2
-1
lines changed Original file line number Diff line number Diff line change 87
87
import org .apache .rocketmq .remoting .exception .RemotingTimeoutException ;
88
88
import org .apache .rocketmq .remoting .exception .RemotingTooMuchRequestException ;
89
89
import org .apache .rocketmq .remoting .protocol .RemotingCommand ;
90
+ import org .apache .rocketmq .remoting .protocol .RequestCode ;
90
91
import org .apache .rocketmq .remoting .protocol .ResponseCode ;
91
92
import org .apache .rocketmq .remoting .proxy .SocksProxyConfig ;
92
93
@@ -604,7 +605,7 @@ private void interruptPullRequests(Set<String> brokerAddrSet) {
604
605
}
605
606
String remoteAddr = RemotingHelper .parseChannelRemoteAddr (responseFuture .getChannel ());
606
607
// interrupt only pull message request
607
- if (brokerAddrSet .contains (remoteAddr ) && (cmd .getCode () == 11 || cmd .getCode () == 361 )) {
608
+ if (brokerAddrSet .contains (remoteAddr ) && (cmd .getCode () == RequestCode . PULL_MESSAGE || cmd .getCode () == RequestCode . LITE_PULL_MESSAGE )) {
608
609
LOGGER .info ("interrupt {}" , cmd );
609
610
responseFuture .interrupt ();
610
611
}
You can’t perform that action at this time.
0 commit comments