From 18efee6b6b30f1339b4bed7fc455cc47549b1cbd Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Mon, 20 Jan 2025 17:40:09 +0800
Subject: [PATCH] refactor(rabbit): 更新队列名称和配置
---
src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java | 5 +----
1 files changed, 1 insertions(+), 4 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java b/src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java
index 366ac20..a20111e 100644
--- a/src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java
+++ b/src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java
@@ -4,7 +4,6 @@
import cc.mrbird.febs.mall.service.IApiMallOrderInfoService;
import cc.mrbird.febs.mall.service.IMemberProfitService;
import cc.mrbird.febs.rabbit.constants.QueueConstants;
-import cc.mrbird.febs.rabbit.enumerates.RabbitQueueEnum;
import cc.mrbird.febs.vip.service.IVipCommonService;
import com.rabbitmq.client.Channel;
import lombok.extern.slf4j.Slf4j;
@@ -12,8 +11,6 @@
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
-
-import java.util.Date;
/**
* @author wzy
@@ -35,7 +32,7 @@
log.info("消费者:{}", new String(message.getBody()));
}
- @RabbitListener(queues = "queue_order_delay_qay")
+ @RabbitListener(queues = "queue_order_delay_qay_xcx")
public void orderCancelDelay(String id) {
try {
orderInfoService.autoCancelOrder(Long.parseLong(id));
--
Gitblit v1.9.1