You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tubemq.apache.org by go...@apache.org on 2021/02/08 11:49:36 UTC
[incubator-tubemq] branch master updated: fix short conversation bug
This is an automated email from the ASF dual-hosted git repository.
gosonzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-tubemq.git
The following commit(s) were added to refs/heads/master by this push:
new 617577c fix short conversation bug
617577c is described below
commit 617577c6be050d86f036ad8e07eee211249d3f97
Author: 曹显乐 <xi...@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;