From b9b263043cbb2e028017b9a5626c664b54513749 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期一, 14 十月 2024 17:46:11 +0800
Subject: [PATCH] 将CMQ替换为rabbitmq
---
fanli/src/main/java/com/yeshi/fanli/controller/admin/UploadController.java | 6 +++++-
1 files changed, 5 insertions(+), 1 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/controller/admin/UploadController.java b/fanli/src/main/java/com/yeshi/fanli/controller/admin/UploadController.java
index a4e732e..d543769 100644
--- a/fanli/src/main/java/com/yeshi/fanli/controller/admin/UploadController.java
+++ b/fanli/src/main/java/com/yeshi/fanli/controller/admin/UploadController.java
@@ -11,6 +11,7 @@
import javax.annotation.Resource;
import com.yeshi.fanli.entity.accept.AdminAcceptData;
+import com.yeshi.fanli.util.mq.rabbit.RabbitmqManager;
import org.springframework.core.task.TaskExecutor;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
@@ -59,6 +60,9 @@
@Resource
private RedisManager redisManager;
+
+ @Resource
+ private RabbitmqManager rabbitmqManager;
// private static final String PAYSUCCESS = "鏀粯鎴愬姛";
// private static final String ORDERCLOSE="璁㈠崟鍏抽棴";
@@ -164,7 +168,7 @@
}
}
- CMQManager.getInstance().addTaoBaoOrderMsg(key);
+ rabbitmqManager.addTaoBaoOrderMsg(key);
try {
// 6灏忔椂鍐呬笉鍐嶅鐞�
if (Constant.IS_OUTNET) {
--
Gitblit v1.8.0