diff --git a/src/main/java/org/redkale/mq/HttpMessageResponse.java b/src/main/java/org/redkale/mq/HttpMessageResponse.java
index b88cc1a81..b7a1bf639 100644
--- a/src/main/java/org/redkale/mq/HttpMessageResponse.java
+++ b/src/main/java/org/redkale/mq/HttpMessageResponse.java
@@ -122,7 +122,7 @@ public class HttpMessageResponse extends HttpResponse {
             }
             return;
         }
-        finishHttpResult(convert, type, new HttpResult(ret));
+        finishHttpResult(convert, type, new HttpResult(ret).convert(ret == null ? null : ret.convert()));
     }
 
     @Override