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/client/v1/UserOrderController.java | 6 +++++-
1 files changed, 5 insertions(+), 1 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/controller/client/v1/UserOrderController.java b/fanli/src/main/java/com/yeshi/fanli/controller/client/v1/UserOrderController.java
index 072f489..03905ae 100644
--- a/fanli/src/main/java/com/yeshi/fanli/controller/client/v1/UserOrderController.java
+++ b/fanli/src/main/java/com/yeshi/fanli/controller/client/v1/UserOrderController.java
@@ -13,6 +13,7 @@
import javax.servlet.http.HttpServletRequest;
import com.yeshi.fanli.util.*;
+import com.yeshi.fanli.util.mq.rabbit.RabbitmqManager;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
@@ -97,6 +98,9 @@
@Resource
private TeamDividentsSourceOrderService teamDividentsSourceOrderService;
+
+ @Resource
+ private RabbitmqManager rabbitmqManager;
/**
* 璁㈠崟鍒楄〃
@@ -660,7 +664,7 @@
try {
isS = orderService.addOrder(or);
if (isS) {
- CMQManager.getInstance().addTaoBaoOrderMsg(order);
+ rabbitmqManager.addTaoBaoOrderMsg(order);
// 鍔犲叆鍒癓ostOrder
LostOrder lo = new LostOrder();
lo.setCreateTime(System.currentTimeMillis());
--
Gitblit v1.8.0