You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2022/01/14 03:06:45 UTC
[rocketmq] branch develop updated: fix build error in RIP-28 at getmQclientFactory (#3753)
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 <li...@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);