lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
Redkale
2021-01-12 10:23:28 +08:00
parent 96c97c7dd2
commit af35e5100e
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/org/redkale/net/sncp/SncpClient.java
View File

@@ -290,8 +290,8 @@ public final class SncpClient {
MessageRecord message = messageClient.createMessageRecord(targetTopic, null, reqbytes); MessageRecord message = messageClient.createMessageRecord(targetTopic, null, reqbytes);
final String tt = targetTopic; final String tt = targetTopic;
return messageClient.sendMessage(message).thenApply(msg -> { return messageClient.sendMessage(message).thenApply(msg -> {
if (msg == 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 = 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; return null;
} }
ByteBuffer buffer = ByteBuffer.wrap(msg.getContent()); ByteBuffer buffer = ByteBuffer.wrap(msg.getContent());