package com.ld.igds.mq;

import com.ld.igds.io.constant.ProtocolEnum;
import lombok.extern.slf4j.Slf4j;
import org.springframework.data.redis.connection.Message;
import org.springframework.stereotype.Component;

/**
 * 接收信息默认实现类
 */
@Slf4j
@Component
public class RedisReceiveDefaultImpl implements RedisReceiveService {

    @Override
    public String getTopic() {
        return ProtocolEnum.TCP_DEFAULT.getCode();
    }

    @Override
    public void onMessage(Message message) {
        log.debug("------------获取到信息----------{}", message.getBody());
    }
}