diff --git a/src/org/redkale/mq/HttpResultCoder.java b/src/org/redkale/mq/HttpResultCoder.java index 11b5da621..d67a79a1b 100644 --- a/src/org/redkale/mq/HttpResultCoder.java +++ b/src/org/redkale/mq/HttpResultCoder.java @@ -44,6 +44,8 @@ public class HttpResultCoder implements MessageCoder { 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 { Convert cc = data.convert(); if (cc == null || !(cc instanceof TextConvert)) cc = JsonConvert.root();