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;