1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
| 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);
| }
|
|
