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-10 13:10:09 +08:00
parent 4f32dcda16
commit c3c3afb3c3
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -288,7 +288,12 @@ public final class SncpClient {
String targetTopic = action.topicTargetParamIndex >= 0 ? (String) params[action.topicTargetParamIndex] : this.topic; String targetTopic = action.topicTargetParamIndex >= 0 ? (String) params[action.topicTargetParamIndex] : this.topic;
if (targetTopic == null) targetTopic = this.topic; if (targetTopic == null) targetTopic = this.topic;
MessageRecord message = messageClient.createMessageRecord(targetTopic, null, reqbytes); MessageRecord message = messageClient.createMessageRecord(targetTopic, null, reqbytes);
final String tt = targetTopic;
return messageClient.sendMessage(message).thenApply(msg -> { 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");
return null;
}
ByteBuffer buffer = ByteBuffer.wrap(msg.getContent()); ByteBuffer buffer = ByteBuffer.wrap(msg.getContent());
checkResult(seqid, action, buffer); checkResult(seqid, action, buffer);