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/job/order/taobao/UpdateOrderJob.java | 6 +++++-
1 files changed, 5 insertions(+), 1 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/job/order/taobao/UpdateOrderJob.java b/fanli/src/main/java/com/yeshi/fanli/job/order/taobao/UpdateOrderJob.java
index 44586f8..17e0946 100644
--- a/fanli/src/main/java/com/yeshi/fanli/job/order/taobao/UpdateOrderJob.java
+++ b/fanli/src/main/java/com/yeshi/fanli/job/order/taobao/UpdateOrderJob.java
@@ -13,6 +13,7 @@
import javax.annotation.Resource;
+import com.yeshi.fanli.util.mq.rabbit.RabbitmqManager;
import org.springframework.stereotype.Component;
import com.xxl.job.core.biz.model.ReturnT;
@@ -69,6 +70,9 @@
@Resource
private CommonOrderService commonOrderService;
+
+ @Resource
+ private RabbitmqManager rabbitmqManager;
/**
@@ -234,7 +238,7 @@
}
- CMQManager.getInstance().addTaoBaoOrderMsg(key);
+ rabbitmqManager.addTaoBaoOrderMsg(key);
try {
// 6灏忔椂鍐呬笉鍐嶅鐞�
--
Gitblit v1.8.0