优化告警逻辑

jetlinks · Jul 1, 2022 · 7dcfabf · 7dcfabf
1 parent dcad116
commit 7dcfabf
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/.../main/java/org/jetlinks/community/rule/engine/device/DeviceAlarmTaskExecutorProvider.java b/.../main/java/org/jetlinks/community/rule/engine/device/DeviceAlarmTaskExecutorProvider.java
@@ -183,7 +183,8 @@ public Flux<Map<String, Object>> doSubscribe(EventBus eventBus) {
                 .accept()
                 //使用cache,多个定时收到相同的数据
                 //通过header来进行判断具体是哪个触发器触发的,应该还有更好的方式.
-                .cache(0);
+                .replay(0)
+                .refCount(1,Duration.ofMillis(10));
 
             for (DeviceAlarmRule.Trigger trigger : rule.getTriggers()) {
                 //QL不存在,理论上不会发生