diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/activity/RocketMqBpmActivityEventListener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/activity/RocketMqBpmActivityEventListener.java
index 1da62614e..07ef0997c 100644
--- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/activity/RocketMqBpmActivityEventListener.java
+++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/activity/RocketMqBpmActivityEventListener.java
@@ -135,7 +135,7 @@ public class RocketMqBpmActivityEventListener extends AbstractBpmnEventListener<
         // 这个 ID 等于 ExecutionId
         dto.setTriggerId(execution.getId());
         dto.setActivityId(execution.getCurrentActivityId());
-        dto.setActivityName(((ExecutionEntityImpl) execution).getCurrentActivityName());
+        dto.setActivityName(execution.getCurrentFlowElement().getName());
         ProcessInstance processInstance = getContext().getProcessInstance(() ->
                 runtimeService.createProcessInstanceQuery().processInstanceId(execution.getProcessInstanceId())
                         .includeProcessVariables().singleResult());