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();

Reply via email to