2020-11-11 23:48:38 +08:00
parent c02e3549eb
commit 66bd1feadf
1 changed files with 1 additions and 0 deletions
--- 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) {