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 7ab2f9b65..2ae5f5e42 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 @@ -63,6 +63,7 @@ import org.apache.rocketmq.client.java.misc.ExecutorServices; import org.apache.rocketmq.client.java.misc.MetadataUtils; import org.apache.rocketmq.client.java.misc.ThreadFactoryImpl; +import org.apache.rocketmq.client.java.misc.Utilities; import org.apache.rocketmq.client.java.route.Endpoints; import org.apache.rocketmq.client.java.rpc.Context; import org.apache.rocketmq.client.java.rpc.RpcClient; @@ -394,8 +395,9 @@ protected void startUp() { () -> { try { log.info("Start to log statistics, clientVersion={}, clientWrapperVersion={}, " - + "clientEndpoints={}, clientId={}", MetadataUtils.getVersion(), - MetadataUtils.getWrapperVersion(), client.getEndpoints(), clientId); + + "clientEndpoints={}, os description=[{}], java description=[{}], clientId={}", + MetadataUtils.getVersion(), MetadataUtils.getWrapperVersion(), client.getEndpoints(), + Utilities.getOsDescription(), Utilities.getJavaDescription(), clientId); client.doStats(); } catch (Throwable t) { log.error("Exception raised during statistics logging, clientId={}", clientId, t); diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/misc/Utilities.java b/java/client/src/main/java/org/apache/rocketmq/client/java/misc/Utilities.java index 9557e1e13..35916a5b6 100644 --- a/java/client/src/main/java/org/apache/rocketmq/client/java/misc/Utilities.java +++ b/java/client/src/main/java/org/apache/rocketmq/client/java/misc/Utilities.java @@ -297,4 +297,10 @@ public static String getOsVersion() { return null; } } + + public static String getJavaDescription() { + return System.getProperty("java.vm.vendor") + + " " + System.getProperty("java.vm.name") + + " " + System.getProperty("java.vm.version"); + } } diff --git a/java/client/src/test/java/org/apache/rocketmq/client/java/misc/UtilitiesTest.java b/java/client/src/test/java/org/apache/rocketmq/client/java/misc/UtilitiesTest.java index 41f408dac..b59c377a7 100644 --- a/java/client/src/test/java/org/apache/rocketmq/client/java/misc/UtilitiesTest.java +++ b/java/client/src/test/java/org/apache/rocketmq/client/java/misc/UtilitiesTest.java @@ -61,4 +61,10 @@ public void testStackTrace() { assertNotNull(stackTrace); assertTrue(stackTrace.length() > 0); } + + @Test + public void testGetJavaDescription() { + final String javaDescription = Utilities.getJavaDescription(); + assertNotNull(javaDescription); + } } \ No newline at end of file