Improvement to Clear Alarm Node

6 years ago · d2919ba30e
1 changed files with 2 additions and 2 deletions
--- a/rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/action/TbClearAlarmNode.java
+++ b/rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/action/TbClearAlarmNode.java
@ -81,8 +81,8 @@ public class TbClearAlarmNode extends TbAbstractAlarmNode<TbClearAlarmNodeConfig
                    }
                    alarm.setStatus(alarm.getStatus().isAck() ? AlarmStatus.CLEARED_ACK : AlarmStatus.CLEARED_UNACK);
                    return Futures.immediateFuture(new AlarmResult(false, false, true, alarm));
-                }, MoreExecutors.directExecutor());
-            }, MoreExecutors.directExecutor());
+                }, ctx.getDbCallbackExecutor());
+            }, ctx.getDbCallbackExecutor());
        }, ctx.getDbCallbackExecutor());
    }
 }