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
27
28
| package cn.iocoder.yudao.module.iot.service.rule.data.action;
|
| import cn.iocoder.yudao.module.iot.core.mq.message.IotDeviceMessage;
| import cn.iocoder.yudao.module.iot.dal.dataobject.rule.IotDataSinkDO;
|
| /**
| * IoT 数据流转目的的执行器 action 接口
| *
| * @author HUIHUI
| */
| public interface IotDataRuleAction {
|
| /**
| * 获取数据流转目的类型
| *
| * @return 数据流转目的类型
| */
| Integer getType();
|
| /**
| * 执行数据流转目的操作
| *
| * @param message 设备消息
| * @param dataSink 数据流转目的
| */
| void execute(IotDeviceMessage message, IotDataSinkDO dataSink);
|
| }
|
|
