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