//package com.ld.igds.protocol.iot.mq;
//
//import com.ld.igds.io.constant.ProtocolEnum;
//import org.springframework.context.annotation.Bean;
//import org.springframework.context.annotation.Configuration;
//import org.springframework.data.redis.connection.RedisConnectionFactory;
//import org.springframework.data.redis.listener.PatternTopic;
//import org.springframework.data.redis.listener.RedisMessageListenerContainer;
//import org.springframework.data.redis.listener.adapter.MessageListenerAdapter;
//
//import java.util.concurrent.CountDownLatch;
//
///**
// * 消息订阅配置
// */
//@Configuration
//public class IotRedisSubConfig {
//
//    /**
//     * 创建连接工厂
//     *
//     * @param connectionFactory
//     * @return
//     */
//    @Bean
//    public RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,
//                                                   MessageListenerAdapter adapter1,MessageListenerAdapter adapter2) {
//        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
//        container.setConnectionFactory(connectionFactory);
//
//        //监听对应的channel
//        container.addMessageListener(adapter1, new PatternTopic(ProtocolEnum.TCP_FZZY_IOT_V3.getCode()));
//
//        //监听对应的channel
//        container.addMessageListener(adapter2, new PatternTopic(ProtocolEnum.TCP_ZLDZ_GRAIN_V1.getCode() + "_LOGIN"));
//
//        return container;
//    }
//
//    /**
//     * 绑定消息监听者和接收监听的方法
//     *
//     * @param receiver
//     * @return
//     */
//    @Bean
//    public MessageListenerAdapter adapter1(IotReceiverServer receiver) {
//        return new MessageListenerAdapter(receiver, "onMessage");
//    }
//    /**
//     * 绑定消息监听者和接收监听的方法
//     *
//     * @param receiver
//     * @return
//     */
//    /**
//     * 绑定消息监听者和接收监听的方法
//     *
//     * @param receiver
//     * @return
//     */
//    @Bean
//    public MessageListenerAdapter adapter2(IotReceiverServer receiver) {
//        return new MessageListenerAdapter(receiver, "onLoginMessage");
//    }
//
//    @Bean
//    IotReceiverServer receiver(CountDownLatch latch) {
//        return new IotReceiverServer(latch);
//    }
//
//
//    @Bean
//    public CountDownLatch latch() {
//        return new CountDownLatch(1);//指定了计数的次数 1
//    }
//
//}