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
29
30
31
32
33
34
35
36
37
38
39
40
41
42
| package cn.iocoder.yudao.module.iot.enums.rule;
|
| import cn.iocoder.yudao.framework.common.core.ArrayValuable;
| import lombok.Getter;
| import lombok.RequiredArgsConstructor;
|
| import java.util.Arrays;
|
| /**
| * IoT 数据目的的类型枚举
| *
| * @author 芋道源码
| */
| @RequiredArgsConstructor
| @Getter
| public enum IotDataSinkTypeEnum implements ArrayValuable<Integer> {
|
| HTTP(1, "HTTP"),
| TCP(2, "TCP"),
| WEBSOCKET(3, "WebSocket"),
|
| MQTT(10, "MQTT"),
|
| DATABASE(20, "Database"),
| REDIS(21, "Redis"),
|
| ROCKETMQ(30, "RocketMQ"),
| RABBITMQ(31, "RabbitMQ"),
| KAFKA(32, "Kafka");
|
| private final Integer type;
|
| private final String name;
|
| public static final Integer[] ARRAYS = Arrays.stream(values()).map(IotDataSinkTypeEnum::getType).toArray(Integer[]::new);
|
| @Override
| public Integer[] array() {
| return ARRAYS;
| }
|
| }
|
|
