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 a76b7b2f6..d29850b28 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 @@ -132,7 +132,8 @@ public class RocketMqMessagePushEventListener implements BpmnMessagePushEventLis return; } if (log.isDebugEnabled()) { - log.debug("RocketMqMessagePushEventListener#onPendingPush...msgTemplateId: {}, receivePerson: {}", event.getNoticeConfig().getNotice().getNoticeMessageId(), JSON.toJSONString(event.getAssigner())); + log.debug("RocketMqMessagePushEventListener#onPendingPush...msgTemplateId: {}, receivePerson: {}", + event.getNoticeConfig().getPending().getPendingMessageId(), JSON.toJSONString(event.getAssigner())); } if (Objects.nonNull(event.getNoticeConfig().getPending())) { MessagePushDTO dto = build(event.getNoticeConfig().getPending().getPendingMessageId(), PROCESS_PUSH_PENDING, @@ -142,7 +143,8 @@ public class RocketMqMessagePushEventListener implements BpmnMessagePushEventLis } if (log.isDebugEnabled()) { - log.debug("RocketMqMessagePushEventListener#onPendingPush...end, msgTemplateId: {}, receivePerson: {}", event.getNoticeConfig().getNotice().getNoticeMessageId(), JSON.toJSONString(event.getAssigner())); + log.debug("RocketMqMessagePushEventListener#onPendingPush...end, msgTemplateId: {}, receivePerson: {}", + event.getNoticeConfig().getPending().getPendingMessageId(), JSON.toJSONString(event.getAssigner())); } } @@ -154,13 +156,16 @@ public class RocketMqMessagePushEventListener implements BpmnMessagePushEventLis return; } if (log.isDebugEnabled()) { - log.debug("RocketMqMessagePushEventListener#onPendingComplete...msgTemplateId: {}, receivePerson: {}", event.getNoticeConfig().getNotice().getNoticeMessageId(), JSON.toJSONString(event.getAssigner())); + log.debug("RocketMqMessagePushEventListener#onPendingComplete...msgTemplateId: {}, receivePerson: {}", + event.getNoticeConfig().getPending().getPendingMessageId(), JSON.toJSONString(event.getAssigner())); } MessagePushDTO dto = build(event.getNoticeConfig().getPending().getPendingMessageId(), PROCESS_PUSH_PENDING_COMPLETE, event, null); sendMessageQueue(dto, PROCESS_PUSH_PENDING_COMPLETE); if (log.isDebugEnabled()) { - log.debug("RocketMqMessagePushEventListener#onPendingComplete...end, msgTemplateId: {}, receivePerson: {}", event.getNoticeConfig().getNotice().getNoticeMessageId(), JSON.toJSONString(event.getAssigner())); + log.debug("RocketMqMessagePushEventListener#onPendingComplete...end, msgTemplateId: {}, receivePerson: " + + "{}", event.getNoticeConfig().getPending().getPendingMessageId(), + JSON.toJSONString(event.getAssigner())); } } @@ -173,13 +178,15 @@ public class RocketMqMessagePushEventListener implements BpmnMessagePushEventLis return; } if (log.isDebugEnabled()) { - log.debug("RocketMqMessagePushEventListener#onSms...msgTemplateId: {}, receivePerson: {}", event.getNoticeConfig().getNotice().getNoticeMessageId(), JSON.toJSONString(event.getAssigner())); + log.debug("RocketMqMessagePushEventListener#onSms...msgTemplateId: {}, receivePerson: {}", + event.getNoticeConfig().getSms().getSmsId(), JSON.toJSONString(event.getAssigner())); } MessagePushDTO dto = build(event.getNoticeConfig().getSms().getSmsId(), PROCESS_PUSH_SMS, event, collectionVariable(event)); sendMessageQueue(dto, PROCESS_PUSH_SMS); if (log.isDebugEnabled()) { - log.debug("RocketMqMessagePushEventListener#onSms...end, msgTemplateId: {}, receivePerson: {}", event.getNoticeConfig().getNotice().getNoticeMessageId(), JSON.toJSONString(event.getAssigner())); + log.debug("RocketMqMessagePushEventListener#onSms...end, msgTemplateId: {}, receivePerson: {}", + event.getNoticeConfig().getSms().getSmsId(), JSON.toJSONString(event.getAssigner())); } }