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 db17579c Polish java example
db17579c is described below
commit db17579cfd1a70407fdfd3b19926a0ca0c65fe7b
Author: Aaron Ai <[email protected]>
AuthorDate: Thu Dec 8 13:13:26 2022 +0800
Polish java example
---
.../apache/rocketmq/client/java/example/AsyncProducerExample.java | 5 +++--
.../rocketmq/client/java/example/ProducerDelayMessageExample.java | 5 +++--
.../rocketmq/client/java/example/ProducerFifoMessageExample.java | 5 +++--
.../rocketmq/client/java/example/ProducerNormalMessageExample.java | 5 +++--
.../client/java/example/ProducerTransactionMessageExample.java | 5 +++--
5 files changed, 15 insertions(+), 10 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 832be4d5..50632c88 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
@@ -52,10 +52,11 @@ public class AsyncProducerExample {
.setCredentialProvider(sessionCredentialsProvider)
.build();
String topic = "yourTopic";
+ // In most case, you don't need to create too many producers,
singleton pattern is recommended.
final Producer producer = provider.newProducerBuilder()
.setClientConfiguration(clientConfiguration)
- // Set the topic name(s), which is optional. It makes producer
could prefetch the topic route before
- // message publishing.
+ // Set the topic name(s), which is optional but recommended. It
makes producer could prefetch the topic
+ // route before message publishing.
.setTopics(topic)
// May throw {@link ClientException} if the producer is not
initialized.
.build();
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 5372a7e8..1d128f32 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
@@ -52,10 +52,11 @@ public class ProducerDelayMessageExample {
.setCredentialProvider(sessionCredentialsProvider)
.build();
String topic = "yourDelayTopic";
+ // In most case, you don't need to create too many producers,
singleton pattern is recommended.
final Producer producer = provider.newProducerBuilder()
.setClientConfiguration(clientConfiguration)
- // Set the topic name(s), which is optional. It makes producer
could prefetch the topic route before
- // message publishing.
+ // Set the topic name(s), which is optional but recommended. It
makes producer could prefetch the topic
+ // route before message publishing.
.setTopics(topic)
// May throw {@link ClientException} if the producer is not
initialized.
.build();
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 ca0ce397..e8bbb055 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
@@ -51,10 +51,11 @@ public class ProducerFifoMessageExample {
.setCredentialProvider(sessionCredentialsProvider)
.build();
String topic = "yourFifoTopic";
+ // In most case, you don't need to create too many producers,
singleton pattern is recommended.
final Producer producer = provider.newProducerBuilder()
.setClientConfiguration(clientConfiguration)
- // Set the topic name(s), which is optional. It makes producer
could prefetch the topic route before
- // message publishing.
+ // Set the topic name(s), which is optional but recommended. It
makes producer could prefetch the topic
+ // route before message publishing.
.setTopics(topic)
// May throw {@link ClientException} if the producer is not
initialized.
.build();
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 f19ef734..b0dde2ca 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
@@ -51,10 +51,11 @@ public class ProducerNormalMessageExample {
.setCredentialProvider(sessionCredentialsProvider)
.build();
String topic = "yourNormalTopic";
+ // In most case, you don't need to create too many producers,
singleton pattern is recommended.
final Producer producer = provider.newProducerBuilder()
.setClientConfiguration(clientConfiguration)
- // Set the topic name(s), which is optional. It makes producer
could prefetch the topic route before
- // message publishing.
+ // Set the topic name(s), which is optional but recommended. It
makes producer could prefetch the topic
+ // route before message publishing.
.setTopics(topic)
// May throw {@link ClientException} if the producer is not
initialized.
.build();
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 a3f90f2f..a538ae0c 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
@@ -59,10 +59,11 @@ public class ProducerTransactionMessageExample {
// Return the transaction resolution according to your business
logic.
return TransactionResolution.COMMIT;
};
+ // In most case, you don't need to create too many producers,
singleton pattern is recommended.
Producer producer = provider.newProducerBuilder()
.setClientConfiguration(clientConfiguration)
- // Set the topic name(s), which is optional. It makes producer
could prefetch the topic route before
- // message publishing.
+ // Set the topic name(s), which is optional but recommended. It
makes producer could prefetch the topic
+ // route before message publishing.
.setTopics(topic)
// Set transactional checker.
.setTransactionChecker(checker)
