//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); // } //}