From abb790da54c23b1179b8bcc136e918ffbaeb52ca Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Fri, 31 Jul 2020 12:00:27 +0800
Subject: [PATCH]

---
 src/org/redkale/mq/HttpMessageProcessor.java | 3 ++-
 src/org/redkale/mq/SncpMessageProcessor.java | 1 +
 2 files changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/org/redkale/mq/HttpMessageProcessor.java b/src/org/redkale/mq/HttpMessageProcessor.java
index 8c20ca99d..a0b00cae4 100644
--- a/src/org/redkale/mq/HttpMessageProcessor.java
+++ b/src/org/redkale/mq/HttpMessageProcessor.java
@@ -89,7 +89,7 @@ public class HttpMessageProcessor implements MessageProcessor {
             servlet.execute(request, response);
         } catch (Throwable ex) {
             if (message.getResptopic() != null && !message.getResptopic().isEmpty()) {
-                HttpMessageResponse.finishHttpResult(finest, message, callback,  producer.getProducer(message), message.getResptopic(), new HttpResult().status(500));
+                HttpMessageResponse.finishHttpResult(finest, message, callback, producer.getProducer(message), message.getResptopic(), new HttpResult().status(500));
             }
             logger.log(Level.SEVERE, HttpMessageProcessor.class.getSimpleName() + " process error, message=" + message, ex);
         }
@@ -102,6 +102,7 @@ public class HttpMessageProcessor implements MessageProcessor {
                 this.cdl.await(30, TimeUnit.SECONDS);
             } catch (Exception ex) {
             }
+            this.cdl = null;
         }
     }
 
diff --git a/src/org/redkale/mq/SncpMessageProcessor.java b/src/org/redkale/mq/SncpMessageProcessor.java
index 82478a51e..9a1125638 100644
--- a/src/org/redkale/mq/SncpMessageProcessor.java
+++ b/src/org/redkale/mq/SncpMessageProcessor.java
@@ -83,6 +83,7 @@ public class SncpMessageProcessor implements MessageProcessor {
                 this.cdl.await(30, TimeUnit.SECONDS);
             } catch (Exception ex) {
             }
+            this.cdl = null;
         }
     }