From 4b7c41159548937efc89a3c3daa0bd786ff1ff4b Mon Sep 17 00:00:00 2001 From: kaikoo <42601684+kingkh1995@users.noreply.github.com> Date: Mon, 6 Nov 2023 10:08:46 +0800 Subject: [PATCH] Update out-of-date java client examples (#627) * update out-of-date java client examples * Remove semaphore from AsyncSimpleConsumerExample Signed-off-by: Aaron Ai --------- Signed-off-by: Aaron Ai Co-authored-by: Aaron Ai --- .../rocketmq/client/java/example/AsyncProducerExample.java | 2 +- .../client/java/example/ProducerDelayMessageExample.java | 2 +- .../client/java/example/ProducerFifoMessageExample.java | 2 +- .../client/java/example/ProducerNormalMessageExample.java | 2 +- .../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 0a52c8253..fe6ba179c 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 static void main(String[] args) throws ClientException, InterruptedExcept 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 a4dcf9619..7c843883d 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 static void main(String[] args) throws ClientException { } // 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 a39a980c5..9b310a802 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 static void main(String[] args) throws ClientException { } // 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 b8e510cec..c8650b80f 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 static void main(String[] args) throws ClientException { } // 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 d05f2a992..8eec6091b 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 static void main(String[] args) throws ClientException { // 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(); } }