From d39acaa9f9a4b8d02eab771c1e7b8645e006f035 Mon Sep 17 00:00:00 2001 From: wangli <274027703@qq.com> Date: Thu, 18 Jan 2024 14:20:15 +0800 Subject: [PATCH] =?UTF-8?q?update=20-=20=E8=B0=83=E6=95=B4=E5=8F=91?= =?UTF-8?q?=E9=80=81=20MQ=20=E7=9A=84=20shardingKey=20=E7=9A=84=E5=80=BC?= =?UTF-8?q?=E7=BB=9F=E4=B8=80=E4=BD=BF=E7=94=A8=E5=AE=9E=E4=BE=8B=20ID?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../listener/activity/RocketMqBpmActivityEventListener.java | 2 +- .../controller/listener/task/RocketMqBpmnTaskEventListener.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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 84341e425..648708463 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 @@ -170,7 +170,7 @@ public class RocketMqBpmActivityEventListener implements BpmnActivityEventListen return; } eventProducer.send(Event.builder() - .shardingKey(dto.getActivityId()) + .shardingKey(dto.getProcessInstanceId()) .eventCode(eventEnum.getEventCode()) .targetId(dto.getActivityId()) .targetType(eventEnum.getTag()) diff --git 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 index b0a5af339..c510e1777 100644 --- 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 @@ -134,7 +134,7 @@ public class RocketMqBpmnTaskEventListener implements BpmnTaskEventListener, Ord return; } eventProducer.send(Event.builder() - .shardingKey(dto.getProcessTaskId()) + .shardingKey(dto.getProcessInstanceId()) .eventCode(eventEnum.getEventCode()) .targetId(dto.getProcessTaskId()) .targetType(eventEnum.getTag())