CMQ改造为rabbitmq

admin

2024-10-16 bd885c7015446c6c0495d3299ef64068a4c9b30e

 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")