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

REQ-2516-调整分批次发送mq消息代码

Browse Source
This commit is contained in:
yangqicheng 2024-07-12 09:51:18 +08:00
parent a67dd3ddfc
commit eee3f4f882
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/notice/RocketMqMessagePushEventListener.java
View File

@ -268,12 +268,16 @@ public class RocketMqMessagePushEventListener extends AbstractBpmnEventListener<
throw new NullPointerException("event不能为空");
}
List<BpmnTaskDelegateAssigner> assigners = event.getAssigners();
if (CollectionUtils.isEmpty(assigners) || assigners.size() <= MQ_ASSIGNER_BATCH_SIZE) {
return Collections.singletonList(build(templateId, type, event, collectionVariable(event)));
}
List<MessagePushDTO> slice = new ArrayList<>();
Map<String, Object> objectMap = collectionVariable(event);
int startIndex = 0;
do {
List<BpmnTaskDelegateAssigner> batchAssigners = assigners.subList(startIndex, Integer.min(startIndex + MQ_ASSIGNER_BATCH_SIZE, assigners.size()));
MessagePushEventImpl messagePushEvent = BeanConverter.convert(event, MessagePushEventImpl.class);
MessagePushEventImpl messagePushEvent = new MessagePushEventImpl(event.getType());
BeanConverter.convert(event, messagePushEvent);
messagePushEvent.setAssigner(batchAssigners);
MessagePushDTO dto = build(templateId, type, messagePushEvent, objectMap);
slice.add(dto);