Merge 96f6040 into 9f95a97

apache · Nov 9, 2020 · 8e2220c · 8e2220c
2 parents 9f95a97 + 96f6040
commit 8e2220c
Showing 1 changed file with 0 additions and 5 deletions.
diff --git a/client/src/main/java/org/apache/rocketmq/client/common/ThreadLocalIndex.java b/client/src/main/java/org/apache/rocketmq/client/common/ThreadLocalIndex.java
@@ -27,15 +27,10 @@ public int getAndIncrement() {
         Integer index = this.threadLocalIndex.get();
         if (null == index) {
             index = Math.abs(random.nextInt());
-            if (index < 0)
-                index = 0;
             this.threadLocalIndex.set(index);
         }
 
         index = Math.abs(index + 1);
-        if (index < 0)
-            index = 0;
-
         this.threadLocalIndex.set(index);
         return index;
     }