From eee3f4f882fc337a393e53b71faac3d96606f5fb Mon Sep 17 00:00:00 2001 From: yangqicheng Date: Fri, 12 Jul 2024 09:51:18 +0800 Subject: [PATCH] =?UTF-8?q?REQ-2516-=E8=B0=83=E6=95=B4=E5=88=86=E6=89=B9?= =?UTF-8?q?=E6=AC=A1=E5=8F=91=E9=80=81mq=E6=B6=88=E6=81=AF=E4=BB=A3?= =?UTF-8?q?=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../listener/notice/RocketMqMessagePushEventListener.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/notice/RocketMqMessagePushEventListener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/notice/RocketMqMessagePushEventListener.java index 952d7a748..a0bdb86cb 100644 --- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/notice/RocketMqMessagePushEventListener.java +++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/notice/RocketMqMessagePushEventListener.java @@ -268,12 +268,16 @@ public class RocketMqMessagePushEventListener extends AbstractBpmnEventListener< throw new NullPointerException("event不能为空"); } List assigners = event.getAssigners(); + if (CollectionUtils.isEmpty(assigners) || assigners.size() <= MQ_ASSIGNER_BATCH_SIZE) { + return Collections.singletonList(build(templateId, type, event, collectionVariable(event))); + } List slice = new ArrayList<>(); Map objectMap = collectionVariable(event); int startIndex = 0; do { List 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);