You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2019/08/30 03:21:10 UTC
[rocketmq-ons] 10/29: Add error log for async send failed
This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a commit to branch pullConsumer
in repository https://gitbox.apache.org/repos/asf/rocketmq-ons.git
commit 64fd96ef65885dc13246f0f702ed49dfe1fa4a1b
Author: ShannonDing <li...@163.com>
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());