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();
+    }
 }

Reply via email to