修复事件无效

jetlinks · Sep 23, 2021 · 29b79fb · 29b79fb
1 parent 58511d9
commit 29b79fb
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...-engine-api/src/main/java/org/jetlinks/rule/engine/defaults/AbstractExecutionContext.java b/...-engine-api/src/main/java/org/jetlinks/rule/engine/defaults/AbstractExecutionContext.java
@@ -65,7 +65,7 @@ public AbstractExecutionContext(String workerId,
         this.eventOutputs = eventOutputs
                 .entrySet()
                 .stream()
-                .collect(Collectors.toMap(Map.Entry::getKey, e -> RuleEngineHooks.wrapOutput(output)));
+                .collect(Collectors.toMap(Map.Entry::getKey, e -> RuleEngineHooks.wrapOutput(e.getValue())));
         this.logger = CompositeLogger.of(logger, new EventLogger(eventBus, job.getInstanceId(), job.getNodeId(), workerId));
         this.globalScope = globalScope;
     }