mirror of
https://github.com/apache/rocketmq.git
synced 2026-09-21 13:49:50 +08:00
[ISSUE #3949] for check style and test case
This commit is contained in:
-10
@@ -110,16 +110,6 @@ public class PopMessageProcessorTest {
|
||||
assertThat(response.getRemark()).contains("topic[" + topic + "] not exist");
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testProcessRequest_SubNotExist() throws RemotingCommandException {
|
||||
brokerController.getConsumerManager().unregisterConsumer(group, clientChannelInfo, false);
|
||||
final RemotingCommand request = createPopMsgCommand();
|
||||
RemotingCommand response = popMessageProcessor.processRequest(handlerContext, request);
|
||||
assertThat(response).isNotNull();
|
||||
assertThat(response.getCode()).isEqualTo(ResponseCode.SUBSCRIPTION_NOT_EXIST);
|
||||
assertThat(response.getRemark()).contains("consumer's group info not exist");
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testProcessRequest_Found() throws RemotingCommandException {
|
||||
GetMessageResult getMessageResult = createGetMessageResult(1);
|
||||
|
||||
Reference in New Issue
Block a user