From bd885c7015446c6c0495d3299ef64068a4c9b30e Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 16 十月 2024 15:00:34 +0800
Subject: [PATCH] CMQ改造为rabbitmq
---
service-push/src/main/java/com/ks/push/manager/rabbitmq/RabbitmqConfig.java | 31 +++++++++++++++++++++----------
1 files changed, 21 insertions(+), 10 deletions(-)
diff --git a/service-push/src/main/java/com/ks/push/manager/rabbitmq/RabbitmqConfig.java b/service-push/src/main/java/com/ks/push/manager/rabbitmq/RabbitmqConfig.java
index a94001f..71c8470 100644
--- a/service-push/src/main/java/com/ks/push/manager/rabbitmq/RabbitmqConfig.java
+++ b/service-push/src/main/java/com/ks/push/manager/rabbitmq/RabbitmqConfig.java
@@ -9,6 +9,7 @@
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
+import org.springframework.lang.Nullable;
import java.util.HashMap;
import java.util.Map;
@@ -22,44 +23,54 @@
@Configuration
public class RabbitmqConfig {
- @Bean
- public Queue tokenInvalidQueue() {
- return new Queue("bpush-token-invalid");
+
+ private Queue createQueue(String queueName) {
+ Map<String, Object> arguments = new HashMap<>();
+ // 璁剧疆娑堟伅鐨勬湁鏁堟椂闂�
+ arguments.put("x-message-ttl", 1000 * 60 * 60 * 24L);
+ return new Queue(queueName, true, false, false, arguments);
}
@Bean
+ public Queue tokenInvalidQueue() {
+ return createQueue("bpush-token-invalid");
+ }
+
+
+
+ @Bean
public Queue xmPushQueue() {
- return new Queue("bpush-xm");
+ return createQueue("bpush-xm");
}
@Bean
public Queue vivoPushQueue() {
- return new Queue("bpush-vivo");
+ return createQueue("bpush-vivo");
}
@Bean
public Queue oppoPushQueue() {
- return new Queue("bpush-oppo");
+ return createQueue("bpush-oppo");
}
@Bean
public Queue mzPushQueue() {
- return new Queue("bpush-mz");
+ return createQueue("bpush-mz");
}
@Bean
public Queue ipushPushQueue() {
- return new Queue("bpush-jpush");
+ return createQueue("bpush-jpush");
}
@Bean
public Queue huaweiPushQueue() {
- return new Queue("bpush-huawei");
+ return createQueue("bpush-huawei");
}
@Bean
public Queue testQueue() {
- return new Queue("test");
+ return createQueue("test");
}
@Bean("pluginDelayExchange")
--
Gitblit v1.8.0