This is an automated email from the ASF dual-hosted git repository. duhengforever pushed a commit to branch OpenMessaging in repository https://gitbox.apache.org/repos/asf/rocketmq-ons.git
commit 64fd96ef65885dc13246f0f702ed49dfe1fa4a1b Author: ShannonDing <[email protected]> AuthorDate: Tue Jun 18 11:10:00 2019 +0800 Add error log for async send failed --- .../java/org/apache/rocketmq/ons/api/impl/rocketmq/ProducerImpl.java | 1 + 1 file changed, 1 insertion(+) diff --git a/ons-core/ons-client/src/main/java/org/apache/rocketmq/ons/api/impl/rocketmq/ProducerImpl.java b/ons-core/ons-client/src/main/java/org/apache/rocketmq/ons/api/impl/rocketmq/ProducerImpl.java index ecb5221..cfbe212 100644 --- a/ons-core/ons-client/src/main/java/org/apache/rocketmq/ons/api/impl/rocketmq/ProducerImpl.java +++ b/ons-core/ons-client/src/main/java/org/apache/rocketmq/ons/api/impl/rocketmq/ProducerImpl.java @@ -199,6 +199,7 @@ public class ProducerImpl extends ONSClientAbstract implements Producer { public void onException(Throwable e) { //String topic = new String(message.getTopic()); //String msgId = new String(message.getMsgID()); + LOGGER.error(String.format("Send message async Exception, %s", message), e); ONSClientException onsEx = checkProducerException(message.getTopic(), message.getMsgID(), e); OnExceptionContext context = new OnExceptionContext(); context.setTopic(message.getTopic());
