[rocketmq] branch develop updated: [ISSUE #5131] Close the producer after the message is sent

[jinrongtong]

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

jinrongtong 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 2bee9d81a [ISSUE #5131] Close the producer after the message is sent
2bee9d81a is described below

commit 2bee9d81aaa653443c4e14b60d985aeb02bb6084
Author: Guocheng Tang <tot...@apache.org>
AuthorDate: Wed Sep 21 08:34:07 2022 +0800

    [ISSUE #5131] Close the producer after the message is sent
---
 .../org/apache/rocketmq/example/namespace/ProducerWithNamespace.java  | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/example/src/main/java/org/apache/rocketmq/example/namespace/ProducerWithNamespace.java
 
b/example/src/main/java/org/apache/rocketmq/example/namespace/ProducerWithNamespace.java
index ccbd6d0de..a8a920b1d 100644
--- 
a/example/src/main/java/org/apache/rocketmq/example/namespace/ProducerWithNamespace.java
+++ 
b/example/src/main/java/org/apache/rocketmq/example/namespace/ProducerWithNamespace.java
@@ -16,11 +16,12 @@
  */
 package org.apache.rocketmq.example.namespace;
 
-import java.nio.charset.StandardCharsets;
 import org.apache.rocketmq.client.producer.DefaultMQProducer;
 import org.apache.rocketmq.client.producer.SendResult;
 import org.apache.rocketmq.common.message.Message;
 
+import java.nio.charset.StandardCharsets;
+
 public class ProducerWithNamespace {
 
     public static final String NAMESPACE = "InstanceTest";
@@ -45,5 +46,6 @@ public class ProducerWithNamespace {
                 e.printStackTrace();
             }
         }
+        producer.shutdown();
     }
 }
\ No newline at end of file