(rocketmq-clients) branch master updated: Optimize ProducerTransactionMessageExample.java demo

[lollipop]

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

lollipop 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 90d9f151 Optimize ProducerTransactionMessageExample.java demo
90d9f151 is described below

commit 90d9f1511a7061c71bef6956f862240c63611349
Author: qianye <wuxingcan....@alibaba-inc.com>
AuthorDate: Fri Nov 7 10:08:09 2025 +0800

    Optimize ProducerTransactionMessageExample.java demo
    
    Optimize ProducerTransactionMessageExample.java demo
---
 .../java/org/apache/rocketmq/client/java/example/ProducerSingleton.java | 2 ++
 .../rocketmq/client/java/example/ProducerTransactionMessageExample.java | 2 ++
 2 files changed, 4 insertions(+)

diff --git 
a/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerSingleton.java
 
b/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerSingleton.java
index 3a57b8f6..e6700e95 100644
--- 
a/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerSingleton.java
+++ 
b/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerSingleton.java
@@ -60,6 +60,8 @@ public class ProducerSingleton {
             .setClientConfiguration(clientConfiguration)
             // Set the topic name(s), which is optional but recommended. It 
makes producer could prefetch
             // the topic route before message publishing.
+            // For transaction producers, it is essential to set topics to 
ensure the reliability of the transaction
+            // checker.
             .setTopics(topics);
         if (checker != null) {
             // Set the transaction checker.
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 8eec6091..427aabf8 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
@@ -45,6 +45,8 @@ public class ProducerTransactionMessageExample {
             return TransactionResolution.COMMIT;
         };
         // Get producer using singleton pattern.
+        // For transaction producers, it is essential to set topics to ensure 
the reliability of the transaction
+        // checker.
         final Producer producer = 
ProducerSingleton.getTransactionalInstance(checker, topic);
         final Transaction transaction = producer.beginTransaction();
         // Define your message body.