Logging instead of swallowing exceptions.

iwordz · Dec 14, 2016 · 91f7978 · 91f7978
1 parent bd69f93
commit 91f7978
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...client/src/main/java/com/alibaba/rocketmq/client/impl/producer/DefaultMQProducerImpl.java b/...client/src/main/java/com/alibaba/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
@@ -760,6 +760,7 @@ public void executeSendMessageHookBefore(final SendMessageContext context) {
                 try {
                     hook.sendMessageBefore(context);
                 } catch (Throwable e) {
+                    log.warn("failed to executeSendMessageHookBefore", e);
                 }
             }
         }
@@ -771,6 +772,7 @@ public void executeSendMessageHookAfter(final SendMessageContext context) {
                 try {
                     hook.sendMessageAfter(context);
                 } catch (Throwable e) {
+                    log.warn("failed to executeSendMessageHookAfter", e);
                 }
             }
         }