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/manager/PushManager.java | 6 +++++-
1 files changed, 5 insertions(+), 1 deletions(-)
diff --git a/service-push/src/main/java/com/ks/push/manager/PushManager.java b/service-push/src/main/java/com/ks/push/manager/PushManager.java
index 3d8f061..7215fec 100644
--- a/service-push/src/main/java/com/ks/push/manager/PushManager.java
+++ b/service-push/src/main/java/com/ks/push/manager/PushManager.java
@@ -4,6 +4,7 @@
import com.ks.push.dao.BPushTaskDao;
import com.ks.push.dto.BPushDeviceDataSet;
import com.ks.push.exception.BPushTaskException;
+import com.ks.push.manager.rabbitmq.RabbitmqManager;
import com.ks.push.pojo.DO.BPushDeviceToken;
import com.ks.push.pojo.DO.BPushPlatformAppInfo;
import com.ks.push.pojo.DO.BPushTask;
@@ -40,6 +41,9 @@
@Resource
private RedisTemplate redisTemplate;
+
+ @Resource
+ private RabbitmqManager rabbitmqManager;
/**
@@ -138,7 +142,7 @@
//淇敼鎬绘暟
pushExcuteResultManager.setDeviceCount(result.getId(), totalValidCount);
}
- CMQManager.getInstance().addToPushQueue(result.getPushPlatform(), dataSet);
+ rabbitmqManager.addToPushQueue(result.getPushPlatform(), dataSet);
}
logger.info("鍔犲叆鎺ㄩ�侀槦鍒�#浠诲姟Id:{}#骞冲彴:{}#鎺ㄩ�佹暟閲�:{}", task.getId(), result.getPushPlatform().name(), count);
}
--
Gitblit v1.8.0