From b91b95bdbe3eeba0c6d9071b1ea6b7c66897b1fa Mon Sep 17 00:00:00 2001 From: xxxxx Date: Tue, 20 Apr 2021 14:34:22 +0800 Subject: [PATCH] feat(test) remove unnessary stub --- .../DefaultMQPushConsumerImplTest.java | 25 ------------------- 1 file changed, 25 deletions(-) diff --git a/client/src/test/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImplTest.java b/client/src/test/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImplTest.java index 7788b6c2..ae8d6a99 100644 --- a/client/src/test/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImplTest.java +++ b/client/src/test/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImplTest.java @@ -53,31 +53,6 @@ public class DefaultMQPushConsumerImplTest { @Rule public ExpectedException thrown = ExpectedException.none(); - @Before - public void setUp() throws Exception { - when(defaultMQPushConsumer.getConsumerGroup()).thenReturn("test_group"); - when(defaultMQPushConsumer.getMessageModel()).thenReturn(MessageModel.CLUSTERING); - when(defaultMQPushConsumer.getConsumeFromWhere()).thenReturn(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET); - when(defaultMQPushConsumer.getConsumeTimestamp()).thenReturn(UtilAll.timeMillisToHumanString3(System.currentTimeMillis() - (1000 * 60 * 30))); - when(defaultMQPushConsumer.getAllocateMessageQueueStrategy()).thenReturn(new AllocateMessageQueueAveragely()); - when(defaultMQPushConsumer.getConsumeThreadMin()).thenReturn(20); - when(defaultMQPushConsumer.getConsumeThreadMax()).thenReturn(30); - when(defaultMQPushConsumer.getConsumeConcurrentlyMaxSpan()).thenReturn(2000); - when(defaultMQPushConsumer.getPullThresholdForQueue()).thenReturn(1000); - when(defaultMQPushConsumer.getPullThresholdForTopic()).thenReturn(-1); - when(defaultMQPushConsumer.getPullThresholdSizeForQueue()).thenReturn(100); - when(defaultMQPushConsumer.getPullThresholdSizeForTopic()).thenReturn(-1); - when(defaultMQPushConsumer.getConsumeMessageBatchMaxSize()).thenReturn(1); - when(defaultMQPushConsumer.getPullBatchSize()).thenReturn(32); - when(defaultMQPushConsumer.getPopInvisibleTime()).thenReturn(60000L); - when(defaultMQPushConsumer.getPopBatchNums()).thenReturn(32); - when(defaultMQPushConsumer.getClientIP()).thenReturn("127.0.0.1"); - when(defaultMQPushConsumer.getInstanceName()).thenReturn("test_instance"); - when(defaultMQPushConsumer.buildMQClientId()).thenCallRealMethod(); - ClientConfig clientConfig = new ClientConfig(); - when(defaultMQPushConsumer.cloneClientConfig()).thenReturn(clientConfig); - when(defaultMQPushConsumer.getConsumeTimeout()).thenReturn(15L); - } @Test public void checkConfigTest() throws MQClientException { -- GitLab