fix Multiple instances in the same application share MQClientInstance

44736c37 · panzhi33 · e9b2d852 · 44736c37
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

client/src/main/java/org/apache/rocketmq/client/ClientConfig.java ...rc/main/java/org/apache/rocketmq/client/ClientConfig.java +1 -1

未找到文件。
--- 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 class ClientConfig {

    public void changeInstanceNameToPID() {
        if (this.instanceName.equals("DEFAULT")) {
-            this.instanceName = String.valueOf(UtilAll.getPid());
+            this.instanceName = UtilAll.getPid()+ "#" + System.nanoTime();
        }
    }