From 8e98dda7953490c6b416941e6b1d245002dbc009 Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Thu, 9 Jul 2020 00:22:19 +0800
Subject: [PATCH]

---
 src/org/redkale/mq/HttpMessageResponse.java | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/src/org/redkale/mq/HttpMessageResponse.java b/src/org/redkale/mq/HttpMessageResponse.java
index d857b3f2f..5c0075883 100644
--- a/src/org/redkale/mq/HttpMessageResponse.java
+++ b/src/org/redkale/mq/HttpMessageResponse.java
@@ -10,6 +10,7 @@ import java.util.logging.Level;
 import org.redkale.convert.*;
 import org.redkale.net.Response;
 import org.redkale.net.http.*;
+import org.redkale.service.RetResult;
 import org.redkale.util.ObjectPool;
 
 /**
@@ -55,6 +56,10 @@ public class HttpMessageResponse extends HttpResponse {
     public static void finishHttpResult(boolean finest, MessageRecord msg, Runnable callback, MessageProducer producer, String resptopic, HttpResult result) {
         if (callback != null) callback.run();
         if (resptopic == null || resptopic.isEmpty()) return;
+        if (result.getResult() instanceof RetResult) {
+            RetResult ret = (RetResult) result.getResult();
+            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);
         byte[] content = HttpResultCoder.getInstance().encode(result);