!1255 【功能新增】IoT: 新增 Kafka、RabbitMQ、RedisStreamMQ 数据桥梁实现

Merge pull request !1255 from puhui999/iot
2025-03-01 15:36:14 +00:00
parent 53693529e1 cb16539b66
commit 6a1798bf6a
11 changed files with 622 additions and 56 deletions
--- a/yudao-module-iot/yudao-module-iot-api/src/main/java/cn/iocoder/yudao/module/iot/enums/rule/IotDataBridgTypeEnum.java
+++ b/yudao-module-iot/yudao-module-iot-api/src/main/java/cn/iocoder/yudao/module/iot/enums/rule/IotDataBridgTypeEnum.java
@@ -22,7 +22,7 @@ public enum IotDataBridgTypeEnum implements ArrayValuable<Integer> {
    MQTT(10),

    DATABASE(20),
-    REDIS(21),
+    REDIS_STREAM(21),

    ROCKETMQ(30),
    RABBITMQ(31),