From 840cea06dbff91994dbee2c60ad0aa90c19954ff Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Wed, 6 Jan 2021 15:07:31 +0800
Subject: [PATCH]

---
 src/org/redkale/mq/HttpMessageResponse.java | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

diff --git a/src/org/redkale/mq/HttpMessageResponse.java b/src/org/redkale/mq/HttpMessageResponse.java
index de08d95c8..434e99b37 100644
--- a/src/org/redkale/mq/HttpMessageResponse.java
+++ b/src/org/redkale/mq/HttpMessageResponse.java
@@ -100,13 +100,17 @@ public class HttpMessageResponse extends HttpResponse {
     }
 
     @Override
-    public void finish(int status, String message) {
-        if (finest) producer.logger.log(Level.FINEST, "HttpMessageResponse.finish status: " + status);
+    public void finish(int status, String msg) {
+        if (status > 400) {
+            producer.logger.log(Level.INFO, "HttpMessageResponse.finish status: " + status + ", message: " + this.message);
+        } else if (finest) {
+            producer.logger.log(Level.FINEST, "HttpMessageResponse.finish status: " + status);
+        }
         if (this.message.isEmptyResptopic()) {
             if (callback != null) callback.run();
             return;
         }
-        finishHttpResult(new HttpResult(message == null ? "" : message).status(status));
+        finishHttpResult(new HttpResult(msg == null ? "" : msg).status(status));
     }
 
     @Override