(rocketmq-clients) branch master updated: Update out-of-date java client examples (#627)

[aaronai]

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

aaronai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git


The following commit(s) were added to refs/heads/master by this push:
     new 4b7c4115 Update out-of-date java client examples (#627)
4b7c4115 is described below

commit 4b7c41159548937efc89a3c3daa0bd786ff1ff4b
Author: kaikoo <42601684+kingkh1...@users.noreply.github.com>
AuthorDate: Mon Nov 6 10:08:46 2023 +0800

    Update out-of-date java client examples (#627)
    
    * update out-of-date java client examples
    
    * Remove semaphore from AsyncSimpleConsumerExample
    
    Signed-off-by: Aaron Ai <yangkun....@gmail.com>
    
    ---------
    
    Signed-off-by: Aaron Ai <yangkun....@gmail.com>
    Co-authored-by: Aaron Ai <yangkun....@gmail.com>
---
 .../org/apache/rocketmq/client/java/example/AsyncProducerExample.java   | 2 +-
 .../rocketmq/client/java/example/ProducerDelayMessageExample.java       | 2 +-
 .../apache/rocketmq/client/java/example/ProducerFifoMessageExample.java | 2 +-
 .../rocketmq/client/java/example/ProducerNormalMessageExample.java      | 2 +-
 .../rocketmq/client/java/example/ProducerTransactionMessageExample.java | 2 +-
 5 files changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/java/client/src/main/java/org/apache/rocketmq/client/java/example/AsyncProducerExample.java
 
b/java/client/src/main/java/org/apache/rocketmq/client/java/example/AsyncProducerExample.java
index 0a52c825..fe6ba179 100644
--- 
a/java/client/src/main/java/org/apache/rocketmq/client/java/example/AsyncProducerExample.java
+++ 
b/java/client/src/main/java/org/apache/rocketmq/client/java/example/AsyncProducerExample.java
@@ -67,6 +67,6 @@ public class AsyncProducerExample {
         Thread.sleep(Long.MAX_VALUE);
         // Close the producer when you don't need it anymore.
         // You could close it manually or add this into the JVM shutdown hook.
-        // producer.shutdown();
+        // producer.close();
     }
 }
diff --git 
a/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerDelayMessageExample.java
 
b/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerDelayMessageExample.java
index a4dcf961..7c843883 100644
--- 
a/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerDelayMessageExample.java
+++ 
b/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerDelayMessageExample.java
@@ -61,6 +61,6 @@ public class ProducerDelayMessageExample {
         }
         // Close the producer when you don't need it anymore.
         // You could close it manually or add this into the JVM shutdown hook.
-        // producer.shutdown();
+        // producer.close();
     }
 }
\ No newline at end of file
diff --git 
a/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerFifoMessageExample.java
 
b/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerFifoMessageExample.java
index a39a980c..9b310a80 100644
--- 
a/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerFifoMessageExample.java
+++ 
b/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerFifoMessageExample.java
@@ -59,6 +59,6 @@ public class ProducerFifoMessageExample {
         }
         // Close the producer when you don't need it anymore.
         // You could close it manually or add this into the JVM shutdown hook.
-        // producer.shutdown();
+        // producer.close();
     }
 }
diff --git 
a/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerNormalMessageExample.java
 
b/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerNormalMessageExample.java
index b8e510ce..c8650b80 100644
--- 
a/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerNormalMessageExample.java
+++ 
b/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerNormalMessageExample.java
@@ -57,6 +57,6 @@ public class ProducerNormalMessageExample {
         }
         // Close the producer when you don't need it anymore.
         // You could close it manually or add this into the JVM shutdown hook.
-        // producer.shutdown();
+        // producer.close();
     }
 }
diff --git 
a/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerTransactionMessageExample.java
 
b/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerTransactionMessageExample.java
index d05f2a99..8eec6091 100644
--- 
a/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerTransactionMessageExample.java
+++ 
b/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerTransactionMessageExample.java
@@ -73,6 +73,6 @@ public class ProducerTransactionMessageExample {
 
         // Close the producer when you don't need it anymore.
         // You could close it manually or add this into the JVM shutdown hook.
-        // producer.shutdown();
+        // producer.close();
     }
 }