You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ji...@apache.org on 2022/09/13 12:11:44 UTC
[rocketmq] branch develop updated: [ISSUE #5043] Fix broker logger replaced by ClientLogger. (#5044)
This is an automated email from the ASF dual-hosted git repository.
jinrongtong 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 c820a6829 [ISSUE #5043] Fix broker logger replaced by ClientLogger. (#5044)
c820a6829 is described below
commit c820a68296d976e865238465f9e474b382ecefe0
Author: echooymxq <ec...@gmail.com>
AuthorDate: Tue Sep 13 20:11:25 2022 +0800
[ISSUE #5043] Fix broker logger replaced by ClientLogger. (#5044)
---
.../rebalance/AbstractAllocateMessageQueueStrategy.java | 10 +++++++++-
.../consumer/rebalance/AllocateMessageQueueAveragely.java | 2 +-
.../rebalance/AllocateMessageQueueAveragelyByCircle.java | 2 +-
3 files changed, 11 insertions(+), 3 deletions(-)
diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AbstractAllocateMessageQueueStrategy.java b/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AbstractAllocateMessageQueueStrategy.java
index e0a050091..39b44e5e0 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AbstractAllocateMessageQueueStrategy.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AbstractAllocateMessageQueueStrategy.java
@@ -27,7 +27,15 @@ import org.apache.rocketmq.logging.InternalLogger;
public abstract class AbstractAllocateMessageQueueStrategy implements AllocateMessageQueueStrategy {
- protected InternalLogger log = ClientLogger.getLog();
+ protected InternalLogger log;
+
+ AbstractAllocateMessageQueueStrategy() {
+ this.log = ClientLogger.getLog();
+ }
+
+ public AbstractAllocateMessageQueueStrategy(InternalLogger log) {
+ this.log = log;
+ }
public boolean check(String consumerGroup, String currentCID, List<MessageQueue> mqAll,
List<String> cidAll) {
diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragely.java b/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragely.java
index d8abd0a01..f420fb255 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragely.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragely.java
@@ -32,7 +32,7 @@ public class AllocateMessageQueueAveragely extends AbstractAllocateMessageQueueS
}
public AllocateMessageQueueAveragely(InternalLogger log) {
- this.log = log;
+ super(log);
}
@Override
diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragelyByCircle.java b/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragelyByCircle.java
index c07ed6809..744c2ac12 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragelyByCircle.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragelyByCircle.java
@@ -32,7 +32,7 @@ public class AllocateMessageQueueAveragelyByCircle extends AbstractAllocateMessa
}
public AllocateMessageQueueAveragelyByCircle(InternalLogger log) {
- this.log = log;
+ super(log);
}
@Override