package com.ld.igds.protocol.zldz.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 = "zldz.redisPublisher";
|
|
@Autowired
|
private RedisTemplate<String, Object> redisTemplate;
|
|
|
/**
|
* 正常返回信息获取
|
*
|
* @param reMessage
|
*/
|
public void publishMessage(String reMessage) {
|
redisTemplate.convertAndSend(ProtocolEnum.TCP_ZLDZ_GRAIN_V1.getCode(), reMessage);
|
log.debug("-----------报文信息存入队列------{}", reMessage);
|
}
|
|
/**
|
* 登录信息获取
|
*
|
* @param sessionKey
|
*/
|
public void publishLoginMessage(String sessionKey) {
|
redisTemplate.convertAndSend(ProtocolEnum.TCP_ZLDZ_GRAIN_V1.getCode() + "_LOGIN", sessionKey);
|
log.debug("-----------登录信息存入队列------{}", sessionKey);
|
}
|
|
}
|
