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 6d6f2efb5..4c9638cc0 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
@@ -363,12 +363,13 @@ public class RocketMqMessagePushEventListener extends AbstractBpmnEventListener<
 
     private Map<String, Object> collectionVariable(MessagePushEvent event) {
         Map<String, Object> variables = new HashMap<>();
-
         BpmnProcessInstanceVO processInstance = getContext().getInstanceVO(() -> getBpmnProcessInstanceVO(event));
         Map<String, Object> originVariables = processInstance.getVariables().entrySet().stream()
                 .filter(e -> Objects.nonNull(e.getKey()) && Objects.nonNull(e.getValue()))
                 .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
-
+        originVariables.forEach((k, v) -> {
+            log.info("流程实例变量 key: {}, value: {}", k, JSONUtil.toJsonStr(v));
+        });
         BpmnTaskDelegateAssigner initiator = BpmnTaskDelegateAssigner.toObjectCompatible(originVariables.get(INTERNAL_INITIATOR));
         if (Objects.isNull(initiator)) {
             initiator = new BpmnTaskDelegateAssigner();