package com.ld.igds.mq;


import org.springframework.data.redis.connection.Message;

/**
 * Redis消息队列信息接收接口，使用RedisPublishService 发布队列信息后，接收信息通过实现当前入口RedisReceiveService接口
 */
public interface RedisReceiveService {


    /**
     * 获取协议，一个话题一个实现类
     *
     * @return
     */
    String getTopic();


    /**
     * 收到信息 队列中的信息
     *
     * @param message
     */
    void onMessage(Message message);
}