This is an automated email from the ASF dual-hosted git repository.
aaronai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
The following commit(s) were added to refs/heads/master by this push:
new 5c225a9 Refine the log (#192)
5c225a9 is described below
commit 5c225a9cb39814051704871ea0a3fa88209ddb22
Author: Aaron Ai <[email protected]>
AuthorDate: Sun Aug 28 13:55:54 2022 +0800
Refine the log (#192)
---
.../apache/rocketmq/client/java/metrics/ClientMeterManager.java | 3 ++-
.../java/org/apache/rocketmq/client/java/metrics/Metric.java | 9 +++++++++
2 files changed, 11 insertions(+), 1 deletion(-)
diff --git
a/java/client/src/main/java/org/apache/rocketmq/client/java/metrics/ClientMeterManager.java
b/java/client/src/main/java/org/apache/rocketmq/client/java/metrics/ClientMeterManager.java
index d71168a..748fb02 100644
---
a/java/client/src/main/java/org/apache/rocketmq/client/java/metrics/ClientMeterManager.java
+++
b/java/client/src/main/java/org/apache/rocketmq/client/java/metrics/ClientMeterManager.java
@@ -76,7 +76,8 @@ public class ClientMeterManager {
public synchronized void reset(Metric metric) {
try {
if (clientMeter.satisfy(metric)) {
- LOGGER.info("Metric settings is satisfied by the current
message meter, clientId={}", clientId);
+ LOGGER.info("Metric settings is satisfied by the current
message meter, metric={}, clientId={}",
+ metric, clientId);
return;
}
if (!metric.isOn()) {
diff --git
a/java/client/src/main/java/org/apache/rocketmq/client/java/metrics/Metric.java
b/java/client/src/main/java/org/apache/rocketmq/client/java/metrics/Metric.java
index 0cb7224..db19fc1 100644
---
a/java/client/src/main/java/org/apache/rocketmq/client/java/metrics/Metric.java
+++
b/java/client/src/main/java/org/apache/rocketmq/client/java/metrics/Metric.java
@@ -17,6 +17,7 @@
package org.apache.rocketmq.client.java.metrics;
+import com.google.common.base.MoreObjects;
import org.apache.rocketmq.client.java.route.Endpoints;
public class Metric {
@@ -35,4 +36,12 @@ public class Metric {
public boolean isOn() {
return on;
}
+
+ @Override
+ public String toString() {
+ return MoreObjects.toStringHelper(this)
+ .add("endpoints", endpoints)
+ .add("on", on)
+ .toString();
+ }
}