From 66bd1feadf3168cb28601d917e8fd598f786368e Mon Sep 17 00:00:00 2001 From: Redkale <8730487+redkale@users.noreply.github.com> Date: Wed, 11 Nov 2020 23:48:38 +0800 Subject: [PATCH] --- src/org/redkale/mq/MessageProducers.java | 1 + 1 file changed, 1 insertion(+) diff --git a/src/org/redkale/mq/MessageProducers.java b/src/org/redkale/mq/MessageProducers.java index e0e39e075..91a0507c8 100644 --- a/src/org/redkale/mq/MessageProducers.java +++ b/src/org/redkale/mq/MessageProducers.java @@ -28,6 +28,7 @@ public class MessageProducers { } public MessageProducer getProducer(MessageRecord message) { + if (this.producers.length == 1) return this.producers[0]; int hash = index.incrementAndGet(); if (index.get() > 1000 * producers.length) { synchronized (index) {