Skip to content

Commit

Permalink
[ROCKETMQ-52] Remove unnecessary stubbing
Browse files Browse the repository at this point in the history
  • Loading branch information
zhouxinyu committed Jan 19, 2017

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
1 parent 9d8bd59 commit 4291348
Showing 1 changed file with 0 additions and 2 deletions.
Original file line number Diff line number Diff line change
@@ -55,7 +55,6 @@
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 void init() throws Exception {
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

0 comments on commit 4291348

Please sign in to comment.