From b4f7de4858133cd188153f714dbedc44db1e5d27 Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Thu, 4 Jun 2020 20:14:16 +0800
Subject: [PATCH]

---
 src/org/redkale/mq/MessageAgent.java         | 1 +
 src/org/redkale/net/sncp/SncpDynServlet.java | 2 +-
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/org/redkale/mq/MessageAgent.java b/src/org/redkale/mq/MessageAgent.java
index 951f83396..7898d72f3 100644
--- a/src/org/redkale/mq/MessageAgent.java
+++ b/src/org/redkale/mq/MessageAgent.java
@@ -159,6 +159,7 @@ public abstract class MessageAgent {
         }
         message.setFormat(ConvertType.BSON);
         message.setResptopic(generateSncpRespTopic());
+        getProducer().apply(message);
         return this.sncpRespProcessor.createFuture(message.getSeqid(), counter);
     }
 
diff --git a/src/org/redkale/net/sncp/SncpDynServlet.java b/src/org/redkale/net/sncp/SncpDynServlet.java
index 672d07f2a..f4f1b88d5 100644
--- a/src/org/redkale/net/sncp/SncpDynServlet.java
+++ b/src/org/redkale/net/sncp/SncpDynServlet.java
@@ -119,7 +119,7 @@ public final class SncpDynServlet extends SncpServlet {
         if (action == null) {
             response.finish(SncpResponse.RETCODE_ILLACTIONID, null);  //无效actionid
         } else {
-            BsonWriter out = action.convert.pollBsonWriter(bufferSupplier);
+            BsonWriter out = bufferSupplier == null ? action.convert.pollBsonWriter() : action.convert.pollBsonWriter(bufferSupplier);
             out.writeTo(DEFAULT_HEADER);
             BsonReader in = action.convert.pollBsonReader();
             SncpAsyncHandler handler = null;