[incubator-tubemq] 19/29: fix short conversation bug

[yuanbo]

This is an automated email from the ASF dual-hosted git repository.

yuanbo pushed a commit to branch TUBEMQ-469
in repository https://gitbox.apache.org/repos/asf/incubator-tubemq.git

commit 8a73c1677e280de33b577d4786ea96346d781248
Author: 曹显乐 <xianle....@vivo.com>
AuthorDate: Tue Feb 2 10:34:11 2021 +0800

    fix short conversation bug
---
 .../org/apache/tubemq/client/producer/RoundRobinPartitionRouter.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/tubemq-client/src/main/java/org/apache/tubemq/client/producer/RoundRobinPartitionRouter.java
 
b/tubemq-client/src/main/java/org/apache/tubemq/client/producer/RoundRobinPartitionRouter.java
index acd03c9..109abdf 100644
--- 
a/tubemq-client/src/main/java/org/apache/tubemq/client/producer/RoundRobinPartitionRouter.java
+++ 
b/tubemq-client/src/main/java/org/apache/tubemq/client/producer/RoundRobinPartitionRouter.java
@@ -18,6 +18,7 @@
 package org.apache.tubemq.client.producer;
 
 import java.util.List;
+import java.util.Random;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.atomic.AtomicInteger;
 import org.apache.tubemq.client.exception.TubeClientException;
@@ -40,7 +41,7 @@ public class RoundRobinPartitionRouter implements 
PartitionRouter {
         }
         AtomicInteger currRouterCount = 
partitionRouterMap.get(message.getTopic());
         if (null == currRouterCount) {
-            AtomicInteger newCounter = new AtomicInteger(0);
+            AtomicInteger newCounter = new AtomicInteger(new 
Random().nextInt());
             currRouterCount = 
partitionRouterMap.putIfAbsent(message.getTopic(), newCounter);
             if (null == currRouterCount) {
                 currRouterCount = newCounter;