From 26e4cd2f4a049fba6f948dfec04a8ddcde35382e Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Tue, 8 Sep 2020 09:54:21 +0800
Subject: [PATCH]

---
 src/org/redkale/mq/HttpMessageResponse.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/org/redkale/mq/HttpMessageResponse.java b/src/org/redkale/mq/HttpMessageResponse.java
index 9597753c6..999403c99 100644
--- a/src/org/redkale/mq/HttpMessageResponse.java
+++ b/src/org/redkale/mq/HttpMessageResponse.java
@@ -62,7 +62,7 @@ public class HttpMessageResponse extends HttpResponse {
             //必须要塞入retcode， 开发者可以无需反序列化ret便可确定操作是否返回成功
             if (!ret.isSuccess()) result.header("retcode", String.valueOf(ret.getRetcode()));
         }
-        //if (msg.format == ConvertType.PROTOBUF && result.convert() == null) result.convert(ProtobufConvert.root());
+        if (msg.format == ConvertType.PROTOBUF && result.convert() == null) result.convert(ConvertFactory.findConvert(msg.format));
         ConvertType format = result.convert() == null ? null : result.convert().getFactory().getConvertType();
         if (finest) {
             Object innerrs = result.getResult();