From 4f5e72a31a0ec80cfa8e6c69c1f39bf4ce24c5f5 Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Mon, 13 Jul 2020 22:56:42 +0800
Subject: [PATCH]

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

diff --git a/src/org/redkale/mq/HttpMessageClient.java b/src/org/redkale/mq/HttpMessageClient.java
index f6236dc56..38607e8e6 100644
--- a/src/org/redkale/mq/HttpMessageClient.java
+++ b/src/org/redkale/mq/HttpMessageClient.java
@@ -53,6 +53,10 @@ public class HttpMessageClient extends MessageClient {
         return messageAgent.generateHttpReqTopic(module, resname);
     }
 
+    public boolean isRetSuccess(HttpResult<byte[]> result) {
+        return result != null && (result.getStatus() == 0 || result.getStatus() == 200) && result.getHeader("retcode") == null;
+    }
+
     public final void produceMessage(HttpSimpleRequest request) {
         produceMessage(generateHttpReqTopic(request, null), ConvertType.JSON, 0, null, request, null);
     }