Skip to content

Commit 3c7c1a8

Browse files
committed
#490 向指定Consumer发起消费消息请求,运维需要。服务端开发完成。
1 parent 39cb522 commit 3c7c1a8

File tree

1 file changed

+0
-8
lines changed

1 file changed

+0
-8
lines changed

rocketmq-broker/src/main/java/com/alibaba/rocketmq/broker/client/net/Broker2Client.java

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -100,14 +100,6 @@ public void operationComplete(ChannelFuture future) throws Exception {
100100
}
101101

102102

103-
public RemotingCommand getConsumerRunningInfo(//
104-
final Channel channel,//
105-
final RemotingCommand request//
106-
) throws RemotingSendRequestException, RemotingTimeoutException, InterruptedException {
107-
return this.brokerController.getRemotingServer().invokeSync(channel, request, 10000);
108-
}
109-
110-
111103
public RemotingCommand callClient(//
112104
final Channel channel,//
113105
final RemotingCommand request//

0 commit comments

Comments
 (0)