From 245d6d6fc7e58360eea323be0879b094cfe3a6e6 Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Thu, 12 Nov 2020 09:08:15 +0800
Subject: [PATCH]

---
 src/org/redkale/mq/MessageAgent.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/org/redkale/mq/MessageAgent.java b/src/org/redkale/mq/MessageAgent.java
index 7b4309b40..3ab046793 100644
--- a/src/org/redkale/mq/MessageAgent.java
+++ b/src/org/redkale/mq/MessageAgent.java
@@ -169,7 +169,7 @@ public abstract class MessageAgent {
         if (this.sncpProducer == null) {
             synchronized (sncpProducerLock) {
                 if (this.sncpProducer == null) {
-                    MessageProducer[] producers = new MessageProducer[Runtime.getRuntime().availableProcessors()];
+                    MessageProducer[] producers = new MessageProducer[2];
                     for (int i = 0; i < producers.length; i++) {
                         MessageProducer producer = createProducer("SncpProducer");
                         producer.startup().join();
@@ -186,7 +186,7 @@ public abstract class MessageAgent {
         if (this.httpProducer == null) {
             synchronized (httpProducerLock) {
                 if (this.httpProducer == null) {
-                    MessageProducer[] producers = new MessageProducer[Runtime.getRuntime().availableProcessors()];
+                    MessageProducer[] producers = new MessageProducer[2];
                     for (int i = 0; i < producers.length; i++) {
                         MessageProducer producer = createProducer("HttpProducer");
                         producer.startup().join();