diff --git a/src/org/redkale/mq/HttpMessageResponse.java b/src/org/redkale/mq/HttpMessageResponse.java index 5c0075883..e1f51e1cd 100644 --- a/src/org/redkale/mq/HttpMessageResponse.java +++ b/src/org/redkale/mq/HttpMessageResponse.java @@ -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)); } diff --git a/src/org/redkale/mq/HttpResultCoder.java b/src/org/redkale/mq/HttpResultCoder.java index d67a79a1b..b5ca3c2a7 100644 --- a/src/org/redkale/mq/HttpResultCoder.java +++ b/src/org/redkale/mq/HttpResultCoder.java @@ -42,10 +42,10 @@ public class HttpResultCoder implements MessageCoder { 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();