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 8622dddd0..79bae021c 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 @@ -117,7 +117,7 @@ public class RocketMqMessagePushEventListener implements BpmnMessagePushEventLis if (Objects.isNull(event.getNoticeConfig()) || !StringUtils.hasLength(event.getNoticeConfig().getPendingMessageId()) || Objects.isNull(event.getAssigner())) { return; } - MessagePushDTO dto = build(event.getNoticeConfig().getNoticeMessageId(), PROCESS_PUSH_PENDING, event, + MessagePushDTO dto = build(event.getNoticeConfig().getPendingMessageId(), PROCESS_PUSH_PENDING, event, collectionVariable(event)); log.info("MessagePushEventListener#onPending MQ.Data: {}", JSON.toJSONString(dto)); sendMessageQueue(dto, PROCESS_PUSH_PENDING); @@ -128,7 +128,7 @@ public class RocketMqMessagePushEventListener implements BpmnMessagePushEventLis if (Objects.isNull(event.getNoticeConfig()) || !StringUtils.hasLength(event.getNoticeConfig().getSmsId()) || Objects.isNull(event.getAssigner())) { return; } - MessagePushDTO dto = build(event.getNoticeConfig().getNoticeMessageId(), PROCESS_PUSH_SMS, event, + MessagePushDTO dto = build(event.getNoticeConfig().getSmsId(), PROCESS_PUSH_SMS, event, collectionVariable(event)); log.info("MessagePushEventListener#onSms MQ.Data: {}", JSON.toJSONString(dto)); sendMessageQueue(dto, PROCESS_PUSH_SMS);