[ROCKETMQ-52] Remove unnecessary stubbing
Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/4291348e Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/4291348e Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/4291348e Branch: refs/heads/ROCKETMQ-57 Commit: 4291348ef7ce4f0cd7ff596e5b0c15908e41cf08 Parents: 9d8bd59 Author: yukon <yu...@apache.org> Authored: Thu Jan 19 15:39:43 2017 +0800 Committer: yukon <yu...@apache.org> Committed: Thu Jan 19 15:45:19 2017 +0800 ---------------------------------------------------------------------- .../apache/rocketmq/client/consumer/DefaultMQPushConsumerTest.java | 2 -- 1 file changed, 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/4291348e/client/src/test/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumerTest.java ---------------------------------------------------------------------- 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 7f5c874..ce8b4d3 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
