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

Browse Source
This commit is contained in:
Redkale
2020-07-09 19:50:06 +08:00
parent 614222bdc3
commit a8a6861a21
2 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/org/redkale/mq/HttpMessageResponse.java
View File

@@ -6,6 +6,7 @@
package org.redkale.mq;
import java.nio.ByteBuffer;
import java.nio.charset.StandardCharsets;
import java.util.logging.Level;
import org.redkale.convert.*;
import org.redkale.net.Response;
@@ -61,7 +62,11 @@ public class HttpMessageResponse extends HttpResponse {
if (!ret.isSuccess()) result.header("retcode", String.valueOf(ret.getRetcode()));
}
ConvertType format = result.convert() == null ? null : result.convert().getFactory().getConvertType();
if (finest) producer.logger.log(Level.FINEST, "HttpMessageProcessor.process seqid=" + msg.getSeqid() + ", result: " + result);
if (finest) {
Object innerrs = result.getResult();
if (innerrs instanceof byte[]) innerrs = new String((byte[]) innerrs, StandardCharsets.UTF_8);
producer.logger.log(Level.FINEST, "HttpMessageProcessor.process seqid=" + msg.getSeqid() + ", content: " + innerrs + ", result: " + result);
}
byte[] content = HttpResultCoder.getInstance().encode(result);
producer.apply(new MessageRecord(msg.getSeqid(), format, resptopic, null, content));
}

4
src/org/redkale/mq/HttpResultCoder.java
View File

@@ -42,10 +42,10 @@ public class HttpResultCoder implements MessageCoder<HttpResult> {
byte[] content;
if (data.getResult() == null) {
content = new byte[0]; //""
} else if (data.getResult() instanceof CharSequence) {
content = MessageCoder.getBytes(data.getResult().toString());
} else if (data.getResult() instanceof byte[]) {
content = (byte[]) data.getResult();
} else if (data.getResult() instanceof CharSequence) {
content = MessageCoder.getBytes(data.getResult().toString());
} else {
Convert cc = data.convert();
if (cc == null || !(cc instanceof TextConvert)) cc = JsonConvert.root();