[rocketmq] branch develop updated: fix build error in RIP-28 at getmQclientFactory (#3753)

[duhengforever]

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 2035e6f  fix build error in RIP-28 at getmQclientFactory (#3753)
2035e6f is described below

commit 2035e6fc5d970bd6f4369c55103855c1167df7bd
Author: dinglei <libya_...@163.com>
AuthorDate: Fri Jan 14 11:06:36 2022 +0800

    fix build error in RIP-28 at getmQclientFactory (#3753)
---
 .../java/org/apache/rocketmq/test/lmq/benchmark/BenchLmqStore.java  | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/test/src/main/java/org/apache/rocketmq/test/lmq/benchmark/BenchLmqStore.java 
b/test/src/main/java/org/apache/rocketmq/test/lmq/benchmark/BenchLmqStore.java
index 392b306..d9335eb 100644
--- 
a/test/src/main/java/org/apache/rocketmq/test/lmq/benchmark/BenchLmqStore.java
+++ 
b/test/src/main/java/org/apache/rocketmq/test/lmq/benchmark/BenchLmqStore.java
@@ -242,7 +242,7 @@ public class BenchLmqStore {
         Map<String, Long> offsetMap = new ConcurrentHashMap<>();
         String statKey = "benchOffset";
         TopicRouteData topicRouteData = 
defaultMQPullConsumers[0].getDefaultMQPullConsumerImpl().
-                getRebalanceImpl().getMqClientFactory().getMQClientAPIImpl().
+                getRebalanceImpl().getmQClientFactory().getMQClientAPIImpl().
                 getTopicRouteInfoFromNameServer(lmqTopic, 3000);
         HashMap<Long, String> brokerMap = 
topicRouteData.getBrokerDatas().get(0).getBrokerAddrs();
         if (brokerMap == null || brokerMap.isEmpty()) {
@@ -277,7 +277,7 @@ public class BenchLmqStore {
                             defaultMQPullConsumer
                                     .getDefaultMQPullConsumerImpl()
                                     .getRebalanceImpl()
-                                    .getMqClientFactory()
+                                    .getmQClientFactory()
                                     
.getMQClientAPIImpl().updateConsumerOffset(brokerAddress, updateHeader, 1000);
                             QueryConsumerOffsetRequestHeader queryHeader = new 
QueryConsumerOffsetRequestHeader();
                             queryHeader.setTopic(lmq);
@@ -286,7 +286,7 @@ public class BenchLmqStore {
                             long newOffset2 = defaultMQPullConsumer
                                     .getDefaultMQPullConsumerImpl()
                                     .getRebalanceImpl()
-                                    .getMqClientFactory()
+                                    .getmQClientFactory()
                                     .getMQClientAPIImpl()
                                     .queryConsumerOffset(brokerAddress, 
queryHeader, 1000);
                             offsetMap.put(lmq, newOffset2);