fix build error in RIP-28 at getmQclientFactory (apache#3753)

devfat · Mar 3, 2022 · 49e8af6 · 49e8af6
1 parent fcb7da5
commit 49e8af6
Showing 1 changed file with 3 additions and 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
@@ -242,7 +242,7 @@ public static void doBenchOffset() throws RemotingException, InterruptedExceptio
         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 void run() {
                             defaultMQPullConsumer
                                     .getDefaultMQPullConsumerImpl()
                                     .getRebalanceImpl()
-                                    .getMqClientFactory()
+                                    .getmQClientFactory()
                                     .getMQClientAPIImpl().updateConsumerOffset(brokerAddress, updateHeader, 1000);
                             QueryConsumerOffsetRequestHeader queryHeader = new QueryConsumerOffsetRequestHeader();
                             queryHeader.setTopic(lmq);
@@ -286,7 +286,7 @@ public void run() {
                             long newOffset2 = defaultMQPullConsumer
                                     .getDefaultMQPullConsumerImpl()
                                     .getRebalanceImpl()
-                                    .getMqClientFactory()
+                                    .getmQClientFactory()
                                     .getMQClientAPIImpl()
                                     .queryConsumerOffset(brokerAddress, queryHeader, 1000);
                             offsetMap.put(lmq, newOffset2);