mirror of
https://github.com/apache/rocketmq.git
synced 2026-09-24 16:04:00 +08:00
fix build error in RIP-28 at getmQClientFactory (#3754)
* fix build error in RIP-28 at getmQclientFactory * fix build error in RIP-28 at getmQclientFactory
This commit is contained in:
@@ -82,7 +82,7 @@ public class TestBenchLmqStore {
|
||||
RebalanceImpl rebalanceImpl = mock(RebalanceImpl.class);
|
||||
when(defaultMQPullConsumerImpl.getRebalanceImpl()).thenReturn(rebalanceImpl);
|
||||
MQClientInstance mqClientInstance = mock(MQClientInstance.class);
|
||||
when(rebalanceImpl.getMqClientFactory()).thenReturn(mqClientInstance);
|
||||
when(rebalanceImpl.getmQClientFactory()).thenReturn(mqClientInstance);
|
||||
MQClientAPIImpl mqClientAPI = mock(MQClientAPIImpl.class);
|
||||
when(mqClientInstance.getMQClientAPIImpl()).thenReturn(mqClientAPI);
|
||||
TopicRouteData topicRouteData = new TopicRouteData();
|
||||
|
||||
Reference in New Issue
Block a user