package com.topdraw.mq.config;

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

@Configuration
public class RabbitMqConfig {

    /** 路由(事件)--direct route.key*/
    public static final String UC_ROUTE_KEY_DIRECT_EVENT_AAA = "uc.route.key.direct.event.aaa";

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

    public static final String UC_EXCHANGE_FANOUT = "uc.fanout";


    /**
     * 处理事件
     * @return org.springframework.amqp.core.Queue
     * @author XiangHan
     * @date 2021/9/7 10:19 上午
     */
    @Bean
    public Queue eventDirect() {
        return new Queue(UC_ROUTE_KEY_DIRECT_EVENT_AAA);
    }
}