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