diff --git a/src/org/redkale/mq/HttpMessageProcessor.java b/src/org/redkale/mq/HttpMessageProcessor.java index 7d4798164..b8a7d78b4 100644 --- a/src/org/redkale/mq/HttpMessageProcessor.java +++ b/src/org/redkale/mq/HttpMessageProcessor.java @@ -117,6 +117,7 @@ public class HttpMessageProcessor implements MessageProcessor { try { this.cdl.await(30, TimeUnit.SECONDS); } catch (Exception ex) { + logger.log(Level.SEVERE, HttpMessageProcessor.class.getSimpleName() + " commit error, restmodule=" + this.restmodule, ex); } this.cdl = null; }