[rocketmq] 01/01: Revert "[ISSUE #5138] Do not throw exception in order producer demo (#5185)"

[lizhanhui]

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 <lizhan...@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);
         }
     }
 }