rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From duhengfore...@apache.org
Subject [rocketmq-ons] 10/25: Add error log for async send failed
Date Wed, 17 Jul 2019 05:35:18 GMT
This is an automated email from the ASF dual-hosted git repository.

duhengforever pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-ons.git

commit 64fd96ef65885dc13246f0f702ed49dfe1fa4a1b
Author: ShannonDing <libya_003@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());


Mime
View raw message