From f4a2f2af94a041a365a7c42bda0d5c3b4084e84b Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Fri, 31 Jul 2020 10:26:26 +0800
Subject: [PATCH]

---
 src/org/redkale/mq/MessageProducers.java | 13 +++++--------
 1 file changed, 5 insertions(+), 8 deletions(-)

diff --git a/src/org/redkale/mq/MessageProducers.java b/src/org/redkale/mq/MessageProducers.java
index 41d95e557..e0e39e075 100644
--- a/src/org/redkale/mq/MessageProducers.java
+++ b/src/org/redkale/mq/MessageProducers.java
@@ -28,14 +28,11 @@ public class MessageProducers {
     }
 
     public MessageProducer getProducer(MessageRecord message) {
-        int hash = message.hash();
-        if (hash == 0) {
-            hash = index.incrementAndGet();
-            if (index.get() > 1000 * producers.length) {
-                synchronized (index) {
-                    if (index.get() > 1000 * producers.length) {
-                        index.addAndGet(-1000 * producers.length);
-                    }
+        int hash = index.incrementAndGet();
+        if (index.get() > 1000 * producers.length) {
+            synchronized (index) {
+                if (index.get() > 1000 * producers.length) {
+                    index.addAndGet(-1000 * producers.length);
                 }
             }
         }