From 0330b023a307a938273e8f4dee0c6b96229739b4 Mon Sep 17 00:00:00 2001
From: lxj <15683799673@163.com>
Date: Wed, 27 Aug 2025 19:18:46 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E6=89=93=E5=8C=85=E5=A4=B1?=
 =?UTF-8?q?=E8=B4=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../rocketmq/producer/ProducerService.java    | 114 +++++++++---------
 1 file changed, 57 insertions(+), 57 deletions(-)

diff --git a/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/producer/ProducerService.java b/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/producer/ProducerService.java
index 7c40a8de..aa14c739 100644
--- a/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/producer/ProducerService.java
+++ b/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/producer/ProducerService.java
@@ -1,65 +1,65 @@
-package org.dromara.sis.rocketmq.producer;
-
-import lombok.extern.slf4j.Slf4j;
-import org.apache.rocketmq.common.message.Message;
-import org.apache.rocketmq.spring.core.RocketMQTemplate;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Qualifier;
-import org.springframework.stereotype.Component;
-
-/**
- * @author lsm
- * @apiNote ProducerService
- * @since 2025/8/26
- */
-@Slf4j
-@Component
-public class ProducerService {
-
-    @Autowired
-    @Qualifier("rocketMQTemplateClusterOne")
-    private RocketMQTemplate rocketMQTemplateClusterOne;
-
+//package org.dromara.sis.rocketmq.producer;
+//
+//import lombok.extern.slf4j.Slf4j;
+//import org.apache.rocketmq.common.message.Message;
+//import org.apache.rocketmq.spring.core.RocketMQTemplate;
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.beans.factory.annotation.Qualifier;
+//import org.springframework.stereotype.Component;
+//
+///**
+// * @author lsm
+// * @apiNote ProducerService
+// * @since 2025/8/26
+// */
+//@Slf4j
+//@Component
+//public class ProducerService {
+//
 //    @Autowired
-//    @Qualifier("rocketMQTemplateClusterTwo")
-//    private RocketMQTemplate rocketMQTemplateClusterTwo;
-
-    /**
-     * 向mq写入消息
-     *
-     * @param topic 消息topic
-     * @param tag   消息tag
-     * @param msg   消息
-     */
-    public void defaultSend(String topic, String tag, String msg) {
-        try {
-            String destination = topic + ":" + tag;
-            // 使用 RocketMQTemplate 的同步发送方法
-            rocketMQTemplateClusterOne.syncSend(destination, msg);
-
-            log.info("发送RocketMQOne消息成功, nameServer:{}", rocketMQTemplateClusterOne.getProducer().getNamesrvAddr());
-        } catch (Exception e) {
-            log.error("发送RocketMQOne消息失败", e);
-        }
-    }
-
-
-    /**
-     * 向mq写入消息
-     *
-     * @param topic 消息topic
-     * @param tag   消息tag
-     * @param msg   消息
-     */
-//    public void clusterSend(String topic, String tag, String msg) {
+//    @Qualifier("rocketMQTemplateClusterOne")
+//    private RocketMQTemplate rocketMQTemplateClusterOne;
+//
+////    @Autowired
+////    @Qualifier("rocketMQTemplateClusterTwo")
+////    private RocketMQTemplate rocketMQTemplateClusterTwo;
+//
+//    /**
+//     * 向mq写入消息
+//     *
+//     * @param topic 消息topic
+//     * @param tag   消息tag
+//     * @param msg   消息
+//     */
+//    public void defaultSend(String topic, String tag, String msg) {
 //        try {
 //            String destination = topic + ":" + tag;
 //            // 使用 RocketMQTemplate 的同步发送方法
-//            rocketMQTemplateClusterTwo.syncSend(destination, msg);
+//            rocketMQTemplateClusterOne.syncSend(destination, msg);
 //
-//            log.info("发送RocketMQTwo消息成功, nameServer:{}", rocketMQTemplateClusterTwo.getProducer().getNamesrvAddr());
+//            log.info("发送RocketMQOne消息成功, nameServer:{}", rocketMQTemplateClusterOne.getProducer().getNamesrvAddr());
 //        } catch (Exception e) {
-//            log.error("发送RocketMQTwo消息失败", e);
+//            log.error("发送RocketMQOne消息失败", e);
 //        }
 //    }
-}
+//
+//
+//    /**
+//     * 向mq写入消息
+//     *
+//     * @param topic 消息topic
+//     * @param tag   消息tag
+//     * @param msg   消息
+//     */
+////    public void clusterSend(String topic, String tag, String msg) {
+////        try {
+////            String destination = topic + ":" + tag;
+////            // 使用 RocketMQTemplate 的同步发送方法
+////            rocketMQTemplateClusterTwo.syncSend(destination, msg);
+////
+////            log.info("发送RocketMQTwo消息成功, nameServer:{}", rocketMQTemplateClusterTwo.getProducer().getNamesrvAddr());
+////        } catch (Exception e) {
+////            log.error("发送RocketMQTwo消息失败", e);
+////        }
+////    }
+//}