From a491941cece9a90d72c9c6b0aab0e718e39dbd3c Mon Sep 17 00:00:00 2001
From: zhongrj <123456>
Date: Mon, 22 Aug 2022 15:54:22 +0800
Subject: [PATCH] 从业记录新增同步sql 修改，用户新增审查逻辑修改，外网部门只更新状态，不更新审查明细，内网状态和明细都更新
---
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