huimv-new-input/huimv-env-input/src/main/java/com/huimv/env/input/config/TopicRabbitMQConfig.java

//package com.huimv.env.input.config;
//
//import com.huimv.env.common.utils.Const;
//import org.springframework.amqp.core.Binding;
//import org.springframework.amqp.core.BindingBuilder;
//import org.springframework.amqp.core.Queue;
//import org.springframework.amqp.core.TopicExchange;
//import org.springframework.context.annotation.Bean;
//import org.springframework.context.annotation.Configuration;
//
///**
// * @Project : huimv.shiwan
// * @Package : com.huimv.biosafety.uface.controller
// * @Description : TODO
// * @Version : 1.0
// * @Author : ZhuoNing
// * @Create : 2020-12-25
// **/
//@Configuration
//public class TopicRabbitMQConfig {
//    //温度
//    @Bean
//    public Queue tempQueue() {
//        return new Queue(Const.QUEUE_ENV_TEMP);
//    }
//    @Bean
//    TopicExchange tempExchange() {
//        return new TopicExchange(Const.EXCHANGE_ENV_TEMP);
//    }
//    @Bean
//    Binding bindingTempExchangeMessage() {
//        return BindingBuilder.bind(tempQueue()).to(tempExchange()).with(Const.ROUTING_KEY_ENV_TEMP);
//    }
//
//    //目标温度
//    @Bean
//    public Queue targetTempQueue() {
//        return new Queue(Const.QUEUE_ENV_TARGET_TEMP);
//    }
//    @Bean
//    TopicExchange targetTempExchange() {
//        return new TopicExchange(Const.EXCHANGE_ENV_TARGET_TEMP);
//    }
//    @Bean
//    Binding bindingTargetTempExchangeMessage() {
//        return BindingBuilder.bind(targetTempQueue()).to(targetTempExchange()).with(Const.ROUTING_KEY_ENV_TARGET_TEMP);
//    }
//    //湿度
//    @Bean
//    public Queue humiQueue() {
//        return new Queue(Const.QUEUE_ENV_HUMI);
//    }
//    @Bean
//    TopicExchange humiExchange() {
//        return new TopicExchange(Const.EXCHANGE_ENV_HUMI);
//    }
//    @Bean
//    Binding bindingTumiExchangeMessage() {
//        return BindingBuilder.bind(humiQueue()).to(humiExchange()).with(Const.ROUTING_KEY_ENV_HUMI);
//    }
//
//    //日龄
//    @Bean
//    public Queue dayAgeQueue() {
//        return new Queue(Const.QUEUE_ENV_DAYAGE);
//    }
//    @Bean
//    TopicExchange dayAgeExchange() {
//        return new TopicExchange(Const.EXCHANGE_ENV_DAYAGE);
//    }
//    @Bean
//    Binding bindingDayAgeExchangeMessage() {
//        return BindingBuilder.bind(dayAgeQueue()).to(dayAgeExchange()).with(Const.ROUTING_KEY_ENV_DAYAGE);
//    }
//
//    //通风
//    @Bean
//    public Queue fengQueue() {
//        return new Queue(Const.QUEUE_ENV_FENG);
//    }
//    @Bean
//    TopicExchange fengExchange() {
//        return new TopicExchange(Const.EXCHANGE_ENV_FENG);
//    }
//    @Bean
//    Binding bindingFengExchangeMessage() {
//        return BindingBuilder.bind(fengQueue()).to(fengExchange()).with(Const.ROUTING_KEY_ENV_FENG);
//    }
//
//    //舍外
//    @Bean
//    public Queue outTempQueue() {
//        return new Queue(Const.QUEUE_ENV_OUT_TEMP);
//    }
//    @Bean
//    TopicExchange outTempExchange() {
//        return new TopicExchange(Const.EXCHANGE_ENV_OUT_TEMP);
//    }
//    @Bean
//    Binding bindingOutTempExchangeMessage() {
//        return BindingBuilder.bind(outTempQueue()).to(outTempExchange()).with(Const.ROUTING_KEY_ENV_OUT_TEMP);
//    }
//
//    //舍内 平均温度
//    @Bean
//    public Queue inTempQueue() {
//        return new Queue(Const.QUEUE_ENV_IN_TEMP);
//    }
//    @Bean
//    TopicExchange inTempExchange() {
//        return new TopicExchange(Const.EXCHANGE_ENV_IN_TEMP);
//    }
//    @Bean
//    Binding bindingInTempExchangeMessage() {
//        return BindingBuilder.bind(inTempQueue()).to(inTempExchange()).with(Const.ROUTING_KEY_ENV_IN_TEMP);
//    }
//
//    //报警
//    @Bean
//    public Queue warningQueue() {
//        return new Queue(Const.QUEUE_ENV_WARNING);
//    }
//    @Bean
//    TopicExchange warningExchange() {
//        return new TopicExchange(Const.EXCHANGE_ENV_WARNING);
//    }
//    @Bean
//    Binding bindingWarningExchangeMessage() {
//        return BindingBuilder.bind(warningQueue()).to(warningExchange()).with(Const.ROUTING_KEY_ENV_WARNING);
//    }
//
//    //湿帘状态
//    @Bean
//    public Queue shilianStatusQueue() {
//        return new Queue(Const.QUEUE_ENV_SHILIAN_STATUS);
//    }
//    @Bean
//    TopicExchange shilianStatusExchange() {
//        return new TopicExchange(Const.EXCHANGE_ENV_SHILIAN_STATUS);
//    }
//    @Bean
//    Binding bindingshilianStatusExchangeMessage() {
//        return BindingBuilder.bind(shilianStatusQueue()).to(shilianStatusExchange()).with(Const.ROUTING_KEY_ENV_SHILIAN_STATUS);
//    }
//
//    //喷雾状态
//    @Bean
//    public Queue penwuStatusQueue() {
//        return new Queue(Const.QUEUE_ENV_PENWU_STATUS);
//    }
//    @Bean
//    TopicExchange penwuStatusExchange() {
//        return new TopicExchange(Const.EXCHANGE_ENV_PENWU_STATUS);
//    }
//    @Bean
//    Binding bindingpenwuStatusExchangeMessage() {
//        return BindingBuilder.bind(penwuStatusQueue()).to(penwuStatusExchange()).with(Const.ROUTING_KEY_ENV_PENWU_STATUS);
//    }
//
//    //日龄温度曲线配置
//    @Bean
//    public Queue dayagePeizhiQueue() {
//        return new Queue(Const.QUEUE_ENV_DAYAGE_PEIZHI);
//    }
//    @Bean
//    TopicExchange dayagePeizhiExchange() {
//        return new TopicExchange(Const.EXCHANGE_ENV_DAYAGE_PEIZHI);
//    }
//    @Bean
//    Binding bindingdayagePeizhiExchangeMessage() {
//        return BindingBuilder.bind(dayagePeizhiQueue()).to(dayagePeizhiExchange()).with(Const.ROUTING_KEY_ENV_DAYAGE_PEIZHI);
//    }
//
//    //风机状态
//    @Bean
//    public Queue fengPeizhiQueue() {
//        return new Queue(Const.QUEUE_ENV_FENG_PEIZHI);
//    }
//    @Bean
//    TopicExchange fengPeizhiExchange() {
//        return new TopicExchange(Const.EXCHANGE_ENV_FENG_PEIZHI);
//    }
//    @Bean
//    Binding bindingfengPeizhiExchangeMessage() {
//        return BindingBuilder.bind(fengPeizhiQueue()).to(fengPeizhiExchange()).with(Const.ROUTING_KEY_ENV_FENG_PEIZHI);
//    }
//
//
//    //CO2
//    @Bean
//    public Queue co2DataQueue() {
//        return new Queue(Const.QUEUE_ENV_CO2_DATA);
//    }
//    @Bean
//    TopicExchange co2DatExchange() {
//        return new TopicExchange(Const.EXCHANGE_ENV_CO2_DATA);
//    }
//    @Bean
//    Binding bindingCo2DatExchangeMessage() {
//        return BindingBuilder.bind(co2DataQueue()).to(co2DatExchange()).with(Const.ROUTING_KEY_ENV_CO2_DATA);
//    }
//
//    //CO2
//    @Bean
//    public Queue yaliDataQueue() {
//        return new Queue(Const.QUEUE_ENV_YALI_DATA);
//    }
//    @Bean
//    TopicExchange yaliDatExchange() {
//        return new TopicExchange(Const.EXCHANGE_ENV_YALI_DATA);
//    }
//    @Bean
//    Binding bindingYaliDatExchangeMessage() {
//        return BindingBuilder.bind(yaliDataQueue()).to(yaliDatExchange()).with(Const.ROUTING_KEY_ENV_YALI_DATA);
//    }
//
//
//    //水暖
//    @Bean
//    public Queue shuinuanDataQueue() {
//        return new Queue(Const.QUEUE_ENV_SHUINUAN_DATA);
//    }
//    @Bean
//    TopicExchange shuinuanDatExchange() {
//        return new TopicExchange(Const.EXCHANGE_ENV_SHUINUAN_DATA);
//    }
//    @Bean
//    Binding bindingshuinuanDatExchangeMessage() {
//        return BindingBuilder.bind(shuinuanDataQueue()).to(shuinuanDatExchange()).with(Const.ROUTING_KEY_ENV_SHUINUAN_DATA);
//    }
//
//    //位置
//    @Bean
//    public Queue weizhiDataQueue() {
//        return new Queue(Const.QUEUE_ENV_WEIZHI_DATA);
//    }
//    @Bean
//    TopicExchange weizhiDatExchange() {
//        return new TopicExchange(Const.EXCHANGE_ENV_WEIZHI_DATA);
//    }
//    @Bean
//    Binding bindingweizhiDatExchangeMessage() {
//        return BindingBuilder.bind(weizhiDataQueue()).to(weizhiDatExchange()).with(Const.ROUTING_KEY_ENV_WEIZHI_DATA);
//    }
//
//    // 水表
//    @Bean
//    public Queue shuibiaoDataQueue() {
//        return new Queue(Const.QUEUE_ENV_SHUIBIAO_DATA);
//    }
//    @Bean
//    TopicExchange shuibiaoDatExchange() {
//        return new TopicExchange(Const.EXCHANGE_ENV_SHUIBIAO_DATA);
//    }
//    @Bean
//    Binding bindingshuibiaoDatExchangeMessage() {
//        return BindingBuilder.bind(shuibiaoDataQueue()).to(shuibiaoDatExchange()).with(Const.ROUTING_KEY_ENV_SHUIBIAO_DATA);
//    }
//
//    //电表
//    @Bean
//    public Queue dianbiaoDataQueue() {
//        return new Queue(Const.QUEUE_ENV_DIANBIAO_DATA);
//    }
//    @Bean
//    TopicExchange dianbiaoDatExchange() {
//        return new TopicExchange(Const.EXCHANGE_ENV_DIANBIAO_DATA);
//    }
//    @Bean
//    Binding bindingdianbiaoDatExchangeMessage() {
//        return BindingBuilder.bind(dianbiaoDataQueue()).to(dianbiaoDatExchange()).with(Const.ROUTING_KEY_ENV_DIANBIAO_DATA);
//    }
//
//    //加热器
//    @Bean
//    public Queue jiareStatusQueue() {
//        return new Queue(Const.QUEUE_ENV_JIARE_STATUS);
//    }
//    @Bean
//    TopicExchange jiareStatusExchange() {
//        return new TopicExchange(Const.EXCHANGE_ENV_JIARE_STATUS);
//    }
//    @Bean
//    Binding bindingjiareStatusExchangeMessage() {
//        return BindingBuilder.bind(jiareStatusQueue()).to(jiareStatusExchange()).with(Const.ROUTING_KEY_ENV_JIARE_STATUS);
//    }
//
//    //小窗
//    @Bean
//    public Queue xiaochuangStatusQueue() {
//        return new Queue(Const.QUEUE_ENV_XIAOCHUANG_STATUS);
//    }
//    @Bean
//    TopicExchange xiaochuangStatusExchange() {
//        return new TopicExchange(Const.EXCHANGE_ENV_XIAOCHUANG_STATUS);
//    }
//    @Bean
//    Binding bindingxiaochuangStatusExchangeMessage() {
//        return BindingBuilder.bind(xiaochuangStatusQueue()).to(xiaochuangStatusExchange()).with(Const.ROUTING_KEY_ENV_XIAOCHUANG_STATUS);
//    }
//
//    //导流板
//    @Bean
//    public Queue daoliuStatusQueue() {
//        return new Queue(Const.QUEUE_ENV_DAOLIU_STATUS);
//    }
//    @Bean
//    TopicExchange daoliuStatusExchange() {
//        return new TopicExchange(Const.EXCHANGE_ENV_DAOLIU_STATUS);
//    }
//    @Bean
//    Binding bindingdaoliuStatusExchangeMessage() {
//        return BindingBuilder.bind(daoliuStatusQueue()).to(daoliuStatusExchange()).with(Const.ROUTING_KEY_ENV_DAOLIU_STATUS);
//    }
//
//    //照明
//    @Bean
//    public Queue zhaomingStatusQueue() {
//        return new Queue(Const.QUEUE_ENV_ZHAOMING_STATUS);
//    }
//    @Bean
//    TopicExchange zhaomingStatusExchange() {
//        return new TopicExchange(Const.EXCHANGE_ENV_ZHAOMING_STATUS);
//    }
//    @Bean
//    Binding bindingzhaomingStatusExchangeMessage() {
//        return BindingBuilder.bind(zhaomingStatusQueue()).to(zhaomingStatusExchange()).with(Const.ROUTING_KEY_ENV_ZHAOMING_STATUS);
//    }
//}