diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/process/RocketMqBpmnProcessEventListener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/process/RocketMqBpmnProcessEventListener.java
index 9d6a263f5..41b0148a0 100644
--- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/process/RocketMqBpmnProcessEventListener.java
+++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/process/RocketMqBpmnProcessEventListener.java
@@ -88,7 +88,8 @@ public class RocketMqBpmnProcessEventListener implements BpmnProcessEventListene
         Deployment deployment =
                 repositoryService.createDeploymentQuery().deploymentId(((ExecutionEntityImpl) event.getEntity()).getDeploymentId())
                         .singleResult();
-        Process mainProcess = repositoryService.getBpmnModel(event.getProcessDefinitionId()).getMainProcess();
+        Process mainProcess =
+                repositoryService.getBpmnModel(((ExecutionEntityImpl) event.getEntity()).getProcessDefinitionId()).getMainProcess();
         ProcessInstanceDTO dto = new ProcessInstanceDTO()
                 .setType(PROCESS_INSTANCE_STARTED)
                 .setCategory(deployment.getCategory())