package com.topdraw.mq.config;


import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitMqConfig {

    /** 交换机--广播*/
    public static final String UC_EXCHANGE_FANOUT = "uc.fanout";

    /** 队列-- */
    public static final String UC_QUEUE_FANOUT_IPTV = "uc.fanout.iptv";
    public static final String UC_QUEUE_FANOUT_WEIXIN = "uc.fanout.weixin";

    @Bean
    FanoutExchange ucFanoutExchange(){
        return ExchangeBuilder.fanoutExchange(UC_EXCHANGE_FANOUT).build();
    }

    @Bean
    Queue ucFanoutQueueIptv(){
        return new Queue(UC_QUEUE_FANOUT_IPTV);
    }

    @Bean
    Queue ucFanoutQueueWeiXin(){
        return new Queue(UC_QUEUE_FANOUT_WEIXIN);
    }

    @Bean
    Binding fanoutExchangeBindingIptv(FanoutExchange ucFanoutExchange , Queue ucFanoutQueueIptv) {
        return BindingBuilder.bind(ucFanoutQueueIptv).to(ucFanoutExchange);
    }

    @Bean
    Binding fanoutExchangeBindingWeiXin(FanoutExchange ucFanoutExchange , Queue ucFanoutQueueWeiXin) {
        return BindingBuilder.bind(ucFanoutQueueWeiXin).to(ucFanoutExchange);
    }

}