From 4291348ef7ce4f0cd7ff596e5b0c15908e41cf08 Mon Sep 17 00:00:00 2001 From: yukon Date: Thu, 19 Jan 2017 15:39:43 +0800 Subject: [PATCH] [ROCKETMQ-52] Remove unnecessary stubbing --- .../rocketmq/client/consumer/DefaultMQPushConsumerTest.java | 2 -- 1 file changed, 2 deletions(-) diff --git a/client/src/test/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumerTest.java b/client/src/test/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumerTest.java index 7f5c8741..ce8b4d3d 100644 --- a/client/src/test/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumerTest.java +++ b/client/src/test/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumerTest.java @@ -55,7 +55,6 @@ import org.mockito.invocation.InvocationOnMock; import org.mockito.junit.MockitoJUnitRunner; import org.mockito.stubbing.Answer; -import static org.apache.rocketmq.client.producer.DefaultMQProducerTest.createTopicRoute; import static org.assertj.core.api.Assertions.assertThat; import static org.mockito.ArgumentMatchers.any; import static org.mockito.ArgumentMatchers.anyBoolean; @@ -111,7 +110,6 @@ public class DefaultMQPushConsumerTest { when(mQClientFactory.findBrokerAddressInSubscribe(anyString(), anyLong(), anyBoolean())).thenReturn(new FindBrokerResult("127.0.0.1:10911", false)); mQClientFactory.registerConsumer(consumerGroup, pushConsumerImpl); mQClientFactory.start(); - when(mQClientAPIImpl.getTopicRouteInfoFromNameServer(anyString(), anyLong())).thenReturn(createTopicRoute()); } @After -- GitLab