src/org/redkale/mq/HttpMessageProcessor.java

@@ -102,6 +102,7 @@ public class HttpMessageProcessor implements MessageProcessor {
                 this.cdl.await(30, TimeUnit.SECONDS);
             } catch (Exception ex) {
             }
+            this.cdl = null;
         }
     }
 

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;
         }
     }