File tree Expand file tree Collapse file tree
remoting/src/main/java/org/apache/rocketmq/remoting/netty Expand file tree Collapse file tree Original file line number Diff line number Diff line change 8787import org .apache .rocketmq .remoting .exception .RemotingTimeoutException ;
8888import org .apache .rocketmq .remoting .exception .RemotingTooMuchRequestException ;
8989import org .apache .rocketmq .remoting .protocol .RemotingCommand ;
90+ import org .apache .rocketmq .remoting .protocol .RequestCode ;
9091import org .apache .rocketmq .remoting .protocol .ResponseCode ;
9192import org .apache .rocketmq .remoting .proxy .SocksProxyConfig ;
9293
@@ -604,7 +605,7 @@ private void interruptPullRequests(Set<String> brokerAddrSet) {
604605 }
605606 String remoteAddr = RemotingHelper .parseChannelRemoteAddr (responseFuture .getChannel ());
606607 // 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 )) {
608609 LOGGER .info ("interrupt {}" , cmd );
609610 responseFuture .interrupt ();
610611 }
You can’t perform that action at this time.
0 commit comments