//package com.ld.igds.protocol.iot.mq;
//
//import com.ld.igds.io.constant.ProtocolEnum;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.data.redis.core.RedisTemplate;
//import org.springframework.stereotype.Component;
//
///**
// * 控制终端作为发布者发布信息，服务端作为订阅者订阅，通道定义为当前协议编码
// */
//@Slf4j
//@Component(PublisherControl.BEAN_ID)
//public class PublisherControl {
//
//    public static final String BEAN_ID = "iot.redisPublisher";
//
//    @Autowired
//    private RedisTemplate<String, Object> redisTemplate;
//
//
//    /**
//     * 正常返回信息获取
//     *
//     * @param reMessage
//     */
//    public void publishMessage(String reMessage) {
//        redisTemplate.convertAndSend(ProtocolEnum.TCP_FZZY_IOT_V3.getCode(), reMessage);
//        log.debug("-----------报文信息存入队列------{}", reMessage);
//    }
//
//    /**
//     * 登录信息获取
//     *
//     * @param sessionKey
//     */
//    public void publishLoginMessage(String sessionKey) {
//        redisTemplate.convertAndSend(ProtocolEnum.TCP_FZZY_IOT_V3.getCode() + "_LOGIN", sessionKey);
//        log.debug("-----------登录信息存入队列------{}", sessionKey);
//    }
//
//}