From 38d775fa2ccd433c727a5b7cec8bed02493df1ec Mon Sep 17 00:00:00 2001
From: zhongrj <123456>
Date: Thu, 18 Aug 2022 09:00:40 +0800
Subject: [PATCH] mq 相关配置去除，启动配置修改
---
src/main/java/org/springblade/modules/rabbitmq/config/MQsender.java | 74 ++++++++++++++++++------------------
1 files changed, 37 insertions(+), 37 deletions(-)
diff --git a/src/main/java/org/springblade/modules/rabbitmq/config/MQsender.java b/src/main/java/org/springblade/modules/rabbitmq/config/MQsender.java
index 089eaca..f8efd08 100644
--- a/src/main/java/org/springblade/modules/rabbitmq/config/MQsender.java
+++ b/src/main/java/org/springblade/modules/rabbitmq/config/MQsender.java
@@ -1,37 +1,37 @@
-package org.springblade.modules.rabbitmq.config;
-
-import org.springblade.modules.rabbitmq.redis.RedisService;
-import org.springblade.modules.rabbitmq.vo.TaskMessage;
-import org.springframework.amqp.core.AmqpTemplate;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Service;
-
-/**
- * 消息发送
- * @author zhongrj
- * @since 2022-04-12
- *
- */
-@Service
-public class MQsender {
-
- @Autowired
- AmqpTemplate amqpTemplate;
-
-
- public void send(Object message){
- String msg = RedisService.beanToString(message);
- amqpTemplate.convertAndSend(MQConfig.QUEUE,msg);
- }
-
- public void sendTaskMessage(TaskMessage message){
- String msg = RedisService.beanToString(message);
- amqpTemplate.convertAndSend(MQConfig.TASK_QUEUE,msg);
- }
-
- public void sendTopic(Object message){
- String msg = RedisService.beanToString(message);
- amqpTemplate.convertAndSend(MQConfig.TOPIC_EXCHANGE,"topic.key1",msg+"1");
- }
-
-}
+//package org.springblade.modules.rabbitmq.config;
+//
+//import org.springblade.modules.rabbitmq.redis.RedisService;
+//import org.springblade.modules.rabbitmq.vo.TaskMessage;
+//import org.springframework.amqp.core.AmqpTemplate;
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.stereotype.Service;
+//
+///**
+// * 消息发送
+// * @author zhongrj
+// * @since 2022-04-12
+// *
+// */
+//@Service
+//public class MQsender {
+//
+// @Autowired
+// AmqpTemplate amqpTemplate;
+//
+//
+// public void send(Object message){
+// String msg = RedisService.beanToString(message);
+// amqpTemplate.convertAndSend(MQConfig.QUEUE,msg);
+// }
+//
+// public void sendTaskMessage(TaskMessage message){
+// String msg = RedisService.beanToString(message);
+// amqpTemplate.convertAndSend(MQConfig.TASK_QUEUE,msg);
+// }
+//
+// public void sendTopic(Object message){
+// String msg = RedisService.beanToString(message);
+// amqpTemplate.convertAndSend(MQConfig.TOPIC_EXCHANGE,"topic.key1",msg+"1");
+// }
+//
+//}
--
Gitblit v1.9.3