From fe78dfa6ed9f7b884914005b70f3b21e5ced0cf4 Mon Sep 17 00:00:00 2001
From: Jay <csj123456>
Date: 星期六, 18 一月 2025 13:59:45 +0800
Subject: [PATCH] 修改mq注册队列
---
shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelElecPredictFinishConsumer.java | 4 ++--
1 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelElecPredictFinishConsumer.java b/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelElecPredictFinishConsumer.java
index c7da9d2..e7432ee 100644
--- a/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelElecPredictFinishConsumer.java
+++ b/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelElecPredictFinishConsumer.java
@@ -6,7 +6,7 @@
import com.iailab.module.model.api.mdk.dto.MdkScheduleReqDTO;
import com.iailab.module.model.enums.ScheduleTriggerMethodEnum;
import com.iailab.module.shasteel.mq.common.constant.CommonConstant;
-import com.iailab.module.shasteel.mq.config.QueueElecPredictFinishConfig;
+import com.iailab.module.shasteel.mq.config.QueuePredictFinishConfig;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
@@ -37,7 +37,7 @@
*
* @param message
*/
- @RabbitListener(queues = QueueElecPredictFinishConfig.QUEUE_NAME)
+ @RabbitListener(queues = QueuePredictFinishConfig.QUEUE_NAME)
public void listen(Message message) {
String messageBody = new String(message.getBody());
log.info("开始执行电力调度，messageBody:" + messageBody);
--
Gitblit v1.9.3