package com.ld.igds.mq;
|
|
import com.ld.igds.util.SpringUtil;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.data.redis.connection.Message;
|
import org.springframework.data.redis.connection.MessageListener;
|
|
|
/**
|
* 消息接收队列入口，根据队列调用不同的消息接收
|
*/
|
@Slf4j
|
public class MySubscribe implements MessageListener {
|
|
|
private ReceiveManager receiveManager;
|
|
|
@Override
|
public void onMessage(Message message, byte[] pattern) {
|
|
if (null == receiveManager) {
|
receiveManager = SpringUtil.getBean(ReceiveManager.class);
|
}
|
|
String topic = new String(message.getChannel());
|
|
topic = topic.substring(RedisMqSubConfig.TOPIC_TAG.length());
|
|
log.debug("---------REDIS消息队列-----Topic={}", topic);
|
|
receiveManager.getRedisReceiveService(topic).onMessage(message);
|
}
|
}
|
