[rocketmq-clients] branch master updated: Emit endpoints of each client during statistics (#230)

[aaronai]

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 f1f92f7  Emit endpoints of each client during statistics (#230)
f1f92f7 is described below

commit f1f92f741698ab375be58225f167351813807744
Author: Aaron Ai <yangkun....@gmail.com>
AuthorDate: Wed Sep 7 11:11:25 2022 +0800

    Emit endpoints of each client during statistics (#230)
---
 .../src/main/java/org/apache/rocketmq/client/java/impl/Client.java   | 5 +++++
 .../main/java/org/apache/rocketmq/client/java/impl/ClientImpl.java   | 5 +++++
 .../java/org/apache/rocketmq/client/java/impl/ClientManagerImpl.java | 5 +++--
 3 files changed, 13 insertions(+), 2 deletions(-)

diff --git 
a/java/client/src/main/java/org/apache/rocketmq/client/java/impl/Client.java 
b/java/client/src/main/java/org/apache/rocketmq/client/java/impl/Client.java
index d5bb57d..edab876 100644
--- a/java/client/src/main/java/org/apache/rocketmq/client/java/impl/Client.java
+++ b/java/client/src/main/java/org/apache/rocketmq/client/java/impl/Client.java
@@ -22,6 +22,11 @@ import org.apache.rocketmq.client.java.misc.ClientId;
 import org.apache.rocketmq.client.java.route.Endpoints;
 
 public interface Client {
+    /**
+     * @return endpoints.
+     */
+    Endpoints getEndpoints();
+
     /**
      * Get the unique client identifier for each client.
      *
diff --git 
a/java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientImpl.java
 
b/java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientImpl.java
index 4745ec5..0d29442 100644
--- 
a/java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientImpl.java
+++ 
b/java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientImpl.java
@@ -486,6 +486,11 @@ public abstract class ClientImpl extends 
AbstractIdleService implements Client,
         return clientManager;
     }
 
+    @Override
+    public Endpoints getEndpoints() {
+        return endpoints;
+    }
+
     /**
      * @see Client#getClientId()
      */
diff --git 
a/java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientManagerImpl.java
 
b/java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientManagerImpl.java
index 49ab080..816183a 100644
--- 
a/java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientManagerImpl.java
+++ 
b/java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientManagerImpl.java
@@ -395,8 +395,9 @@ public class ClientManagerImpl extends ClientManager {
         scheduler.scheduleWithFixedDelay(
             () -> {
                 try {
-                    LOGGER.info("Start to log statistics, clientVersion={}, 
clientWrapperVersion={}, clientId={}",
-                        MetadataUtils.getVersion(), 
MetadataUtils.getWrapperVersion(), clientId);
+                    LOGGER.info("Start to log statistics, clientVersion={}, 
clientWrapperVersion={}, "
+                            + "clientEndpoints={}, clientId={}", 
MetadataUtils.getVersion(),
+                        MetadataUtils.getWrapperVersion(), 
client.getEndpoints(), clientId);
                     client.doStats();
                 } catch (Throwable t) {
                     LOGGER.error("Exception raised during statistics logging, 
clientId={}", clientId, t);