diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/notice/RocketMqMessagePushEventListener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/notice/RocketMqMessagePushEventListener.java index 9cb2c3832..a43219ea8 100644 --- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/notice/RocketMqMessagePushEventListener.java +++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/notice/RocketMqMessagePushEventListener.java @@ -158,7 +158,8 @@ public class RocketMqMessagePushEventListener implements BpmnMessagePushEventLis Map variables = new HashMap<>(); BpmnProcessInstanceVO processInstance = getBpmnProcessInstanceVO(event); - Map originVariables = processInstance.getVariables(); + Map originVariables = new HashMap<>(processInstance.getVariables()); + BpmnTaskDelegateAssigner initiator = (BpmnTaskDelegateAssigner) originVariables.getOrDefault(INTERNAL_INITIATOR, new BpmnTaskDelegateAssigner()); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");