From 68d78a4aa4f8dfe63dddb03fb8b96352a9e9e2cc Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Sun, 28 Jun 2020 19:28:56 +0800
Subject: [PATCH]

---
 src/org/redkale/mq/HttpMessageProcessor.java | 2 +-
 src/org/redkale/mq/HttpMessageResponse.java  | 5 +++--
 2 files changed, 4 insertions(+), 3 deletions(-)

diff --git a/src/org/redkale/mq/HttpMessageProcessor.java b/src/org/redkale/mq/HttpMessageProcessor.java
index fabcc2fd2..ad0044f5a 100644
--- a/src/org/redkale/mq/HttpMessageProcessor.java
+++ b/src/org/redkale/mq/HttpMessageProcessor.java
@@ -85,7 +85,7 @@ public class HttpMessageProcessor implements MessageProcessor {
             servlet.execute(request, response);
         } catch (Exception ex) {
             if (message.getResptopic() != null && !message.getResptopic().isEmpty()) {
-                HttpMessageResponse.finishHttpResult(message, callback, producer, message.getResptopic(), new HttpResult().status(500));
+                HttpMessageResponse.finishHttpResult(finest, message, callback, producer, message.getResptopic(), new HttpResult().status(500));
             }
             logger.log(Level.SEVERE, HttpMessageProcessor.class.getSimpleName() + " process error, message=" + message, ex);
         } finally {
diff --git a/src/org/redkale/mq/HttpMessageResponse.java b/src/org/redkale/mq/HttpMessageResponse.java
index e2710335e..d857b3f2f 100644
--- a/src/org/redkale/mq/HttpMessageResponse.java
+++ b/src/org/redkale/mq/HttpMessageResponse.java
@@ -49,13 +49,14 @@ public class HttpMessageResponse extends HttpResponse {
     }
 
     public void finishHttpResult(HttpResult result) {
-        finishHttpResult(this.message, this.callback, this.producer, message.getResptopic(), result);
+        finishHttpResult(this.finest, this.message, this.callback, this.producer, message.getResptopic(), result);
     }
 
-    public static void finishHttpResult(MessageRecord msg, Runnable callback, MessageProducer producer, String resptopic, HttpResult result) {
+    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;
         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);
         producer.apply(new MessageRecord(msg.getSeqid(), format, resptopic, null, content));
     }