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 cd21d8f1a58882cacaf63c8f8db3b2bcf387185a Author: gosonzhang <[email protected]> AuthorDate: Mon Feb 8 22:34:08 2021 +0800 [TUBEMQ-555] short session data can only be written to a specific partition (addendum) (#423) Co-authored-by: 曹显乐 <[email protected]> Co-authored-by: gosonzhang <[email protected]> Co-authored-by: 曹显乐 <[email protected]> --- .../org/apache/tubemq/client/producer/RoundRobinPartitionRouter.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 109abdf..ec74ce5 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,8 +18,8 @@ package org.apache.tubemq.client.producer; import java.util.List; -import java.util.Random; import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.ThreadLocalRandom; import java.util.concurrent.atomic.AtomicInteger; import org.apache.tubemq.client.exception.TubeClientException; import org.apache.tubemq.corebase.Message; @@ -41,7 +41,7 @@ public class RoundRobinPartitionRouter implements PartitionRouter { } AtomicInteger currRouterCount = partitionRouterMap.get(message.getTopic()); if (null == currRouterCount) { - AtomicInteger newCounter = new AtomicInteger(new Random().nextInt()); + AtomicInteger newCounter = new AtomicInteger(ThreadLocalRandom.current().nextInt()); currRouterCount = partitionRouterMap.putIfAbsent(message.getTopic(), newCounter); if (null == currRouterCount) { currRouterCount = newCounter;
