wangli/workflow-engine
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update - 调整发送 MQ 的 shardingKey 的值统一使用实例 ID

Browse Source
This commit is contained in:
wangli 2024-01-18 14:20:15 +08:00
parent cfba5e58a4
commit d39acaa9f9
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/activity/RocketMqBpmActivityEventListener.java
View File

@ -170,7 +170,7 @@ public class RocketMqBpmActivityEventListener implements BpmnActivityEventListen
return; return;
} }
eventProducer.send(Event.builder() eventProducer.send(Event.builder()
.shardingKey(dto.getActivityId()) .shardingKey(dto.getProcessInstanceId())
.eventCode(eventEnum.getEventCode()) .eventCode(eventEnum.getEventCode())
.targetId(dto.getActivityId()) .targetId(dto.getActivityId())
.targetType(eventEnum.getTag()) .targetType(eventEnum.getTag())

2
workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/RocketMqBpmnTaskEventListener.java
View File

@ -134,7 +134,7 @@ public class RocketMqBpmnTaskEventListener implements BpmnTaskEventListener, Ord
return; return;
} }
eventProducer.send(Event.builder() eventProducer.send(Event.builder()
.shardingKey(dto.getProcessTaskId()) .shardingKey(dto.getProcessInstanceId())
.eventCode(eventEnum.getEventCode()) .eventCode(eventEnum.getEventCode())
.targetId(dto.getProcessTaskId()) .targetId(dto.getProcessTaskId())
.targetType(eventEnum.getTag()) .targetType(eventEnum.getTag())