From 7fa83e5dd03f7896bd1d1e8c47f5e926ff3d4ba0 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 16 十月 2024 14:12:24 +0800
Subject: [PATCH] CMQ改造为rabbitmq
---
service-push/src/main/java/com/ks/push/controller/PushCallbackController.java | 9 ++++++---
1 files changed, 6 insertions(+), 3 deletions(-)
diff --git a/service-push/src/main/java/com/ks/push/controller/PushCallbackController.java b/service-push/src/main/java/com/ks/push/controller/PushCallbackController.java
index f902f73..2e1600f 100644
--- a/service-push/src/main/java/com/ks/push/controller/PushCallbackController.java
+++ b/service-push/src/main/java/com/ks/push/controller/PushCallbackController.java
@@ -4,7 +4,7 @@
import com.alibaba.fastjson.JSONObject;
import com.ks.push.dto.mq.InvalidDeviceTokenInfo;
import com.ks.push.manager.BPushPlatformAppInfoManager;
-import com.ks.push.manager.CMQManager;
+import com.ks.push.manager.rabbitmq.RabbitmqManager;
import com.ks.push.pojo.DO.PushPlatform;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -30,6 +30,9 @@
@Resource
private BPushPlatformAppInfoManager bPushPlatformAppInfoManager;
+
+ @Resource
+ private RabbitmqManager rabbitmqManager;
//鍥炶皟鎺ュ彛璇︽儏锛歨ttps://developer.huawei.com/consumer/cn/doc/development/HMSCore-Guides/msg-receipt-guide-0000001050040176#ZH-CN_TOPIC_0000001087208860__p121151147184318
@@ -65,7 +68,7 @@
logger.debug("鍗庝负娑堟伅鍥炴墽-鎺ㄩ�佸け璐ワ細bigTag-{} token-{} status-{}", bigTag, token, status);
if (status == 2 || status == 5 || status == 10) {
//鍒犻櫎鏃犳晥璁惧
- CMQManager.getInstance().addInvalidDevieToken(new InvalidDeviceTokenInfo(appCode, PushPlatform.hw, token));
+ rabbitmqManager.addInvalidDevieToken(new InvalidDeviceTokenInfo(appCode, PushPlatform.hw, token));
}
}
}
@@ -104,7 +107,7 @@
String[] regIds = regIdStr.split(",");
for (String rid : regIds) {
//鍒犻櫎鏃犳晥璁惧
- CMQManager.getInstance().addInvalidDevieToken(new InvalidDeviceTokenInfo(appCode, PushPlatform.xm, rid));
+ rabbitmqManager.addInvalidDevieToken(new InvalidDeviceTokenInfo(appCode, PushPlatform.xm, rid));
}
break;
}
--
Gitblit v1.8.0