This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new bfaef39 fix build error in RIP-28 at getmQClientFactory (#3754)
bfaef39 is described below
commit bfaef39f081a287c133e02af8bb3914c3116481a
Author: dinglei <[email protected]>
AuthorDate: Fri Jan 14 11:38:50 2022 +0800
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
---
test/src/test/java/org/apache/rocketmq/test/lmq/TestBenchLmqStore.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/test/src/test/java/org/apache/rocketmq/test/lmq/TestBenchLmqStore.java
b/test/src/test/java/org/apache/rocketmq/test/lmq/TestBenchLmqStore.java
index 98bb8bf..3457d61 100644
--- a/test/src/test/java/org/apache/rocketmq/test/lmq/TestBenchLmqStore.java
+++ b/test/src/test/java/org/apache/rocketmq/test/lmq/TestBenchLmqStore.java
@@ -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();