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/06/28 03:36:28 UTC
[rocketmq-ons] 05/11: Call onException instead of throw exception
when async sending
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 3f9457e265a6fdece1a3ac8147adab3396c7fd12
Author: ShannonDing <li...@163.com>
AuthorDate: Mon Jun 17 16:30:20 2019 +0800
Call onException instead of throw exception when async sending
---
.../org/apache/rocketmq/ons/api/impl/rocketmq/ProducerImpl.java | 8 +++++++-
1 file changed, 7 insertions(+), 1 deletion(-)
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 6118435..921861a 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
@@ -169,7 +169,13 @@ public class ProducerImpl extends ONSClientAbstract implements Producer {
message.setMsgID(MessageClientIDSetter.getUniqID(msgRMQ));
} catch (Exception e) {
LOGGER.error(String.format("Send message async Exception, %s", message), e);
- throw checkProducerException(message.getTopic(), message.getMsgID(), e);
+ //throw checkProducerException(message.getTopic(), message.getMsgID(), e);
+ ONSClientException clientException = checkProducerException(message.getTopic(), message.getMsgID(), e);
+ OnExceptionContext context = new OnExceptionContext();
+ context.setException(clientException);
+ context.setTopic(message.getTopic());
+ context.setMessageId(message.getMsgID());
+ sendCallback.onException(context);
}
}