From 31a3d28d48d05937f9601ebf1f8ba230ee25864e Mon Sep 17 00:00:00 2001
From: 101captain <237651143@qq.com>
Date: 星期五, 08 四月 2022 11:02:49 +0800
Subject: [PATCH] 花城消息队列修改提交
---
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/message/RaffleMessage.java | 8 ++++----
1 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/message/RaffleMessage.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/message/RaffleMessage.java
index bc446b7..bae83ae 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/message/RaffleMessage.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/message/RaffleMessage.java
@@ -26,7 +26,7 @@
*/
@Component
public class RaffleMessage {
- public static final String DELAYED_QUEUE="raffle.queue";
+ public static final String DELAYED_QUEUE="huacheng.raffle.queue";
@Resource
private ComActRaffleDao comActRaffleDao;
@@ -66,7 +66,7 @@
}
comActRaffle.setStatus(3);
comActRaffleDao.updateById(comActRaffle);
- rabbitTemplate.convertAndSend("raffle.exchange", "raffle.key", comActRaffleVO, message -> {
+ rabbitTemplate.convertAndSend("huacheng.raffle.exchange", "huacheng.raffle.key", comActRaffleVO, message -> {
message.getMessageProperties().setHeader("x-delay", dateToSecond(comActRaffle.getRaffleStopTime()));
return message;
});
@@ -74,7 +74,7 @@
if(comActRaffle!=null&&comActRaffle.getStatus()==0&&comActRaffle.getStartTime().before(new Date())){
comActRaffle.setStatus(1);
comActRaffleDao.updateById(comActRaffle);
- rabbitTemplate.convertAndSend("raffle.exchange", "raffle.key", comActRaffleVO, message -> {
+ rabbitTemplate.convertAndSend("huacheng.raffle.exchange", "huacheng.raffle.key", comActRaffleVO, message -> {
message.getMessageProperties().setHeader("x-delay", dateToSecond(comActRaffle.getStopTime()));
return message;
});
@@ -82,7 +82,7 @@
if(comActRaffle!=null&&comActRaffle.getStatus()==1&&comActRaffle.getStopTime().before(new Date())){
comActRaffle.setStatus(2);
comActRaffleDao.updateById(comActRaffle);
- rabbitTemplate.convertAndSend("raffle.exchange", "raffle.key", comActRaffleVO, message -> {
+ rabbitTemplate.convertAndSend("huacheng.raffle.exchange", "huacheng.raffle.key", comActRaffleVO, message -> {
message.getMessageProperties().setHeader("x-delay", dateToSecond(comActRaffle.getLotteryTime()));
return message;
});
--
Gitblit v1.7.1