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/util/CMQManager.java | 82 -----------------------------------------
1 files changed, 0 insertions(+), 82 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/util/CMQManager.java b/fanli/src/main/java/com/yeshi/fanli/util/CMQManager.java
index d76168a..17a352c 100644
--- a/fanli/src/main/java/com/yeshi/fanli/util/CMQManager.java
+++ b/fanli/src/main/java/com/yeshi/fanli/util/CMQManager.java
@@ -93,88 +93,6 @@
return cmqManager;
}
- /**
- * 鍙戦�佽鍗曟秷鎭�
- *
- * @param orderId
- */
- public void addTaoBaoOrderMsg(String orderId) {
- if (!StringUtil.isNullOrEmpty(orderId)) {
- tdmqUtil.sendMsg(QUEUENAME_ORDER, orderId);
- }
- }
-
- /**
- * 娑堣垂娣樺疂璁㈠崟娑堟伅
- *
- * @param count
- */
- public List<String> consumeTaoBaoOrderMsg(int count) {
- List<String> resultList = new ArrayList<>();
- List<Message> list = tdmqUtil.recieveMsg(count, QUEUENAME_ORDER);
-
- if (list != null)
- for (Message msg : list) {
- String result = msg.msgBody;
- resultList.add(result);
- // 鍒犻櫎娑堟伅
- tdmqUtil.deleteMsg(QUEUENAME_ORDER, msg.receiptHandle);
- }
- return resultList;
- }
-
- /**
- * 鍒犻櫎娣樺疂璁㈠崟娑堟伅
- *
- * @param receiptHandle
- */
- public void deleteTaoBaoOrderMsg(String receiptHandle) {
-
- tdmqUtil.deleteMsg(QUEUENAME_ORDER, receiptHandle);
-
- }
-
- /**
- * 鍙戦�佽鍗曟秷鎭紙鍒氬垰浜х敓鐨勮鍗曪級
- *
- * @param orderId
- */
- public void addTaoBaoNewOrderMsg(String orderId) {
- if (!StringUtil.isNullOrEmpty(orderId)) {
- tdmqUtil.sendMsg(QUEUENAME_NEW_ORDER, orderId);
- }
- }
-
- /**
- * 娑堣垂娣樺疂璁㈠崟娑堟伅锛堝垰鍒氫骇鐢熺殑璁㈠崟锛�
- *
- * @param count
- */
- public List<String> consumeTaoBaoNewOrderMsg(int count) {
- List<String> resultList = new ArrayList<>();
- List<Message> list = tdmqUtil.recieveMsg(count, QUEUENAME_NEW_ORDER);
-
- if (list != null)
- for (Message msg : list) {
- String result = msg.msgBody;
- resultList.add(result);
- // 鍒犻櫎娑堟伅
- tdmqUtil.deleteMsg(QUEUENAME_NEW_ORDER, msg.receiptHandle);
- }
- return resultList;
- }
-
-
- /**
- * 鍒犻櫎娣樺疂璁㈠崟娑堟伅锛堝垰鍒氫骇鐢熺殑璁㈠崟锛�
- *
- * @param receiptHandle
- */
- public void deleteTaoBaoNewOrderMsg(String receiptHandle) {
-
- tdmqUtil.deleteMsg(QUEUENAME_NEW_ORDER, receiptHandle);
-
- }
/**
* 娣诲姞鎻愮幇缁撴灉娑堟伅
--
Gitblit v1.8.0