package com.upyuns.platform.rs.datacenter.config;

import com.github.wxiaoqi.security.common.config.rabbit.BindDTO;
import com.github.wxiaoqi.security.common.config.rabbit.RabbitCommonConfig;
import org.springframework.context.annotation.Configuration;

import java.util.ArrayList;

import static com.github.wxiaoqi.security.common.config.rabbit.RabbitConstant.*;

/**
 * @author libin
 * @version 1.0
 * @description
 * @data 2019/10/17 17:23
 */
@Configuration
public class RabbitConfig extends RabbitCommonConfig {
    /**
     * 获取成功入库数据。
     */
    public static final String IMAGE_INPUT_LOG_QUEUE = "image.input.log.queue";

    static {
        myQueue = new ArrayList<BindDTO>() {{
            //添加接收
            //入库日志队列+数据中心主题+入库完成KEY
            add(new BindDTO(IMAGE_INPUT_LOG_QUEUE, DATACENTER_TOPIC, KEY_IMAGE_INPUT_SUCC));
        }};
    }
}


