From 048e1e3f85cf3245edc6747e59aad122d680a998 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=96=AF=E7=8B=82=E7=9A=84=E7=8B=AE=E5=AD=90Li?=
 <15040126243@163.com>
Date: Fri, 20 Sep 2024 17:18:22 +0800
Subject: [PATCH] =?UTF-8?q?fix=20=E4=BF=AE=E5=A4=8D=20=E4=B9=A6=E5=86=99?=
 =?UTF-8?q?=E9=94=99=E8=AF=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../dromara/stream/producer/TransactionRocketProducer.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/ruoyi-example/ruoyi-test-mq/src/main/java/org/dromara/stream/producer/TransactionRocketProducer.java b/ruoyi-example/ruoyi-test-mq/src/main/java/org/dromara/stream/producer/TransactionRocketProducer.java
index b6477bdd..cef54bb3 100644
--- a/ruoyi-example/ruoyi-test-mq/src/main/java/org/dromara/stream/producer/TransactionRocketProducer.java
+++ b/ruoyi-example/ruoyi-test-mq/src/main/java/org/dromara/stream/producer/TransactionRocketProducer.java
@@ -28,8 +28,8 @@ public class TransactionRocketProducer {
         List<String> tags = Arrays.asList("TAG-1", "TAG-2", "TAG-3");
         for (int i = 0; i < 3; i++) {
             Message<String> message = MessageBuilder.withPayload("===>事务消息-" + i).build();
-            //destination formats: `topicName:tags` message – message Message arg – ext arg
-            TransactionSendResult res = rocketMQTemplate.sendMessageInTransaction("transaction_topic:" + tags.get(i), message, i + 1);
+            // destination formats: `topicName:tags` message – message Message arg – ext arg
+            TransactionSendResult res = rocketMQTemplate.sendMessageInTransaction("transaction-topic:" + tags.get(i), message, i + 1);
             if (res.getLocalTransactionState().equals(LocalTransactionState.COMMIT_MESSAGE) && res.getSendStatus().equals(SendStatus.SEND_OK)) {
                 log.info("【生产者】事物消息发送成功；成功结果：{}", res);
             } else {