1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
| package com.fastbee.mq.service;
|
| import com.fastbee.common.core.mq.message.DeviceMessage;
|
| /**
| * 设备消息推送mq
| * @author bill
| */
| public interface IMessagePublishService {
|
|
| /**
| * 发布消息到mq
| * @param message 设备消息
| * @param channel 推送channel
| */
| public void publish(Object message,String channel);
|
| }
|
|
