[rocketmq] branch develop updated: [ISSUE #5138] Do not throw exception in order producer demo (#5185)

[dinglei]

This is an automated email from the ASF dual-hosted git repository.

dinglei pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new d40765db4 [ISSUE #5138] Do not throw exception in order producer demo 
(#5185)
d40765db4 is described below

commit d40765db49ace7d984967f616b7a66684658b363
Author: alexcao <35793943+alexcao2...@users.noreply.github.com>
AuthorDate: Mon Sep 26 09:29:15 2022 +0800

    [ISSUE #5138] Do not throw exception in order producer demo (#5185)
    
    Co-authored-by: 勇敢的心 <9076189+mave...@user.noreply.gitee.com>
---
 .../java/org/apache/rocketmq/example/ordermessage/Producer.java   | 8 +++-----
 1 file changed, 3 insertions(+), 5 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 c5d864fa3..8ee11bf2b 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,7 +16,6 @@
  */
 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;
@@ -24,13 +23,11 @@ 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 UnsupportedEncodingException 
{
+    public static void main(String[] args) throws MQClientException {
         try {
             DefaultMQProducer producer = new 
DefaultMQProducer("please_rename_unique_group_name");
             producer.start();
@@ -54,8 +51,9 @@ public class Producer {
             }
 
             producer.shutdown();
-        } catch (MQClientException | RemotingException | MQBrokerException | 
InterruptedException e) {
+        } catch (Exception e) {
             e.printStackTrace();
+            throw new MQClientException(e.getMessage(), null);
         }
     }
 }