update - 调整 Activity 事件发送 MQ 的 messageKey

2024-02-27 15:42:36 +08:00 · 2024-02-27 15:42:36 +08:00 · bd961669d1
commit bd961669d1
parent df4a3ec355
1 changed files with 1 additions and 1 deletions
--- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/RocketMqBpmnTaskEventListener.java
+++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/RocketMqBpmnTaskEventListener.java
@ -145,7 +145,7 @@ public class RocketMqBpmnTaskEventListener implements BpmnTaskEventListener, Ord
        eventProducer.send(Event.builder()
                .shardingKey(dto.getProcessInstanceId())
                .eventCode(eventEnum.getEventCode())
-                .targetId(dto.getProcessTaskId())
+                .targetId(dto.getProcessInstanceId())
                .targetType(eventEnum.getTag())
                .data(dto)
                .build());