From af35e5100e5defc24ce6b1ce7965af835a421929 Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Tue, 12 Jan 2021 10:23:28 +0800
Subject: [PATCH]

---
 src/org/redkale/net/sncp/SncpClient.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/org/redkale/net/sncp/SncpClient.java b/src/org/redkale/net/sncp/SncpClient.java
index 3e400346f..0c0b141df 100644
--- a/src/org/redkale/net/sncp/SncpClient.java
+++ b/src/org/redkale/net/sncp/SncpClient.java
@@ -290,8 +290,8 @@ public final class SncpClient {
             MessageRecord message = messageClient.createMessageRecord(targetTopic, null, reqbytes);
             final String tt = targetTopic;
             return messageClient.sendMessage(message).thenApply(msg -> {
-                if (msg == null) {
-                    logger.log(Level.SEVERE, action.method + " sncp mq(params: " + convert.convertTo(params) + ", message: " + message + ") deal error, this.topic = " + this.topic + ", targetTopic = " + tt + ", result = null");
+                if (msg == null || msg.getContent() == null) {
+                    logger.log(Level.SEVERE, action.method + " sncp mq(params: " + convert.convertTo(params) + ", message: " + message + ") deal error, this.topic = " + this.topic + ", targetTopic = " + tt + ", result = " + msg);
                     return null;
                 }
                 ByteBuffer buffer = ByteBuffer.wrap(msg.getContent());