From 4882427b4ce72b2c5b85ebc71251ef041af2f769 Mon Sep 17 00:00:00 2001 From: "kaiyi.lk" Date: Sat, 7 May 2022 10:38:46 +0800 Subject: [PATCH] [ISSUE #3949] for check style and test case --- .../broker/processor/PopMessageProcessorTest.java | 10 ---------- pom.xml | 1 + 2 files changed, 1 insertion(+), 10 deletions(-) diff --git a/broker/src/test/java/org/apache/rocketmq/broker/processor/PopMessageProcessorTest.java b/broker/src/test/java/org/apache/rocketmq/broker/processor/PopMessageProcessorTest.java index 67b4fb96cb..85582fcff9 100644 --- a/broker/src/test/java/org/apache/rocketmq/broker/processor/PopMessageProcessorTest.java +++ b/broker/src/test/java/org/apache/rocketmq/broker/processor/PopMessageProcessorTest.java @@ -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); diff --git a/pom.xml b/pom.xml index def3cb5cee..9caa47358d 100644 --- a/pom.xml +++ b/pom.xml @@ -244,6 +244,7 @@ */*.iml docs/** localbin/** + conf/rmq-proxy.json