fixed unlimited error messages in TbMsgGeneratorNode

6 years ago · d5b28222a3
1 changed files with 2 additions and 1 deletions
--- a/rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/debug/TbMsgGeneratorNode.java
+++ b/rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/debug/TbMsgGeneratorNode.java
@ -104,9 +104,10 @@ public class TbMsgGeneratorNode implements TbNode {
                        }
                    },
                    t -> {
-                        if (initialized) {
+                        if (initialized && (config.getMsgCount() == TbMsgGeneratorNodeConfiguration.UNLIMITED_MSG_COUNT || currentMsgCount < config.getMsgCount())) {
                            ctx.tellFailure(msg, t);
                            scheduleTickMsg(ctx);
+                            currentMsgCount++;
                        }
                    });
        }