From 94a527c339af0308b5d43fd1d404766889ab04a4 Mon Sep 17 00:00:00 2001 From: tgen Date: Tue, 28 Sep 2021 15:39:35 +0800 Subject: [PATCH] [ISSUE #3288] Fix producer always timeouts while sending first message (#3383) --- .../src/main/java/org/apache/rocketmq/common/UtilAll.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/common/src/main/java/org/apache/rocketmq/common/UtilAll.java b/common/src/main/java/org/apache/rocketmq/common/UtilAll.java index 9971f334..ea22aa73 100644 --- a/common/src/main/java/org/apache/rocketmq/common/UtilAll.java +++ b/common/src/main/java/org/apache/rocketmq/common/UtilAll.java @@ -21,7 +21,6 @@ import java.io.ByteArrayOutputStream; import java.io.File; import java.io.IOException; import java.lang.management.ManagementFactory; -import java.lang.management.RuntimeMXBean; import java.net.Inet4Address; import java.net.Inet6Address; import java.net.InetAddress; @@ -52,12 +51,11 @@ public class UtilAll { public static final String YYYY_MM_DD_HH_MM_SS_SSS = "yyyy-MM-dd#HH:mm:ss:SSS"; public static final String YYYYMMDDHHMMSS = "yyyyMMddHHmmss"; final static char[] HEX_ARRAY = "0123456789ABCDEF".toCharArray(); + final static String HOST_NAME = ManagementFactory.getRuntimeMXBean().getName(); // format: "pid@hostname" public static int getPid() { - RuntimeMXBean runtime = ManagementFactory.getRuntimeMXBean(); - String name = runtime.getName(); // format: "pid@hostname" try { - return Integer.parseInt(name.substring(0, name.indexOf('@'))); + return Integer.parseInt(HOST_NAME.substring(0, HOST_NAME.indexOf('@'))); } catch (Exception e) { return -1; } -- GitLab