From b78326d869a09ed9f37b85dc957b39dff7a4ef87 Mon Sep 17 00:00:00 2001
From: Kingdon1992 <wangqingsong@qudian.com>
Date: Wed, 7 Apr 2021 14:56:53 +0800
Subject: [PATCH] [ISSUE #2783] fix_bug_in_ThreadLocalIndex

---
 .../org/apache/rocketmq/client/common/ThreadLocalIndex.java  | 5 ++---
 1 file changed, 2 insertions(+), 3 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
index c0b04cae..891c17e3 100644
--- a/client/src/main/java/org/apache/rocketmq/client/common/ThreadLocalIndex.java
+++ b/client/src/main/java/org/apache/rocketmq/client/common/ThreadLocalIndex.java
@@ -30,9 +30,8 @@ public class ThreadLocalIndex {
             this.threadLocalIndex.set(index);
         }
 
-        index = Math.abs(index + 1);
-        this.threadLocalIndex.set(index);
-        return index;
+        this.threadLocalIndex.set(++index);
+        return Math.abs(index);
     }
 
     @Override
-- 
GitLab