From d3a3364cfcaa59e061070edd41174085037635e0 Mon Sep 17 00:00:00 2001
From: yangqicheng <yangqicheng@axzo.cn>
Date: Tue, 9 Jul 2024 09:53:37 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8DPROCESS=5FACTIVITY=5FEND?=
 =?UTF-8?q?=E4=BA=8B=E4=BB=B6,activityName=E5=80=BC=E4=B8=BA=E7=A9=BA?=
 =?UTF-8?q?=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../listener/activity/RocketMqBpmActivityEventListener.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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());