You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by li...@apache.org on 2022/09/26 01:54:29 UTC
[rocketmq] 01/01: Revert "[ISSUE #5138] Do not throw exception in order producer demo (#5185)"
This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a commit to branch revert-5185-issue_5138_alt2
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
commit f0b33b198e3027e7154c3ac12164a478b4e8f6f3
Author: Zhanhui Li <li...@apache.org>
AuthorDate: Mon Sep 26 09:54:16 2022 +0800
Revert "[ISSUE #5138] Do not throw exception in order producer demo (#5185)"
This reverts commit d40765db49ace7d984967f616b7a66684658b363.
---
.../java/org/apache/rocketmq/example/ordermessage/Producer.java | 8 +++++---
1 file changed, 5 insertions(+), 3 deletions(-)
diff --git a/example/src/main/java/org/apache/rocketmq/example/ordermessage/Producer.java b/example/src/main/java/org/apache/rocketmq/example/ordermessage/Producer.java
index 8ee11bf2b..c5d864fa3 100644
--- a/example/src/main/java/org/apache/rocketmq/example/ordermessage/Producer.java
+++ b/example/src/main/java/org/apache/rocketmq/example/ordermessage/Producer.java
@@ -16,6 +16,7 @@
*/
package org.apache.rocketmq.example.ordermessage;
+import org.apache.rocketmq.client.exception.MQBrokerException;
import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.client.producer.MessageQueueSelector;
@@ -23,11 +24,13 @@ import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.message.Message;
import org.apache.rocketmq.common.message.MessageQueue;
import org.apache.rocketmq.remoting.common.RemotingHelper;
+import org.apache.rocketmq.remoting.exception.RemotingException;
+import java.io.UnsupportedEncodingException;
import java.util.List;
public class Producer {
- public static void main(String[] args) throws MQClientException {
+ public static void main(String[] args) throws UnsupportedEncodingException {
try {
DefaultMQProducer producer = new DefaultMQProducer("please_rename_unique_group_name");
producer.start();
@@ -51,9 +54,8 @@ public class Producer {
}
producer.shutdown();
- } catch (Exception e) {
+ } catch (MQClientException | RemotingException | MQBrokerException | InterruptedException e) {
e.printStackTrace();
- throw new MQClientException(e.getMessage(), null);
}
}
}