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);
     }
 

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;