From 44736c3760b9caa0aad21b8df7a3e53bebfd07b8 Mon Sep 17 00:00:00 2001 From: panzhi33 Date: Tue, 16 Mar 2021 12:21:32 +0800 Subject: [PATCH] fix Multiple instances in the same application share MQClientInstance --- .../src/main/java/org/apache/rocketmq/client/ClientConfig.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/client/src/main/java/org/apache/rocketmq/client/ClientConfig.java b/client/src/main/java/org/apache/rocketmq/client/ClientConfig.java index d0ae5e1b831..bcd3f9b2052 100644 --- a/client/src/main/java/org/apache/rocketmq/client/ClientConfig.java +++ b/client/src/main/java/org/apache/rocketmq/client/ClientConfig.java @@ -94,7 +94,7 @@ public void setInstanceName(String instanceName) { public void changeInstanceNameToPID() { if (this.instanceName.equals("DEFAULT")) { - this.instanceName = String.valueOf(UtilAll.getPid()); + this.instanceName = UtilAll.getPid()+ "#" + System.nanoTime(); } }