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) {