From d3c23d72dd36b5fff013a378b142cccb7db1f34f Mon Sep 17 00:00:00 2001
From: wangli <274027703@qq.com>
Date: Thu, 7 Dec 2023 19:18:40 +0800
Subject: [PATCH] =?UTF-8?q?update=20-=20=E7=A7=BB=E9=99=A4=E6=B5=81?=
 =?UTF-8?q?=E7=A8=8B=E5=8F=98=E9=87=8F=E6=BA=90=E6=95=B0=E6=8D=AE=E4=B8=AD?=
 =?UTF-8?q?=E7=9A=84=E7=A9=BA=20key=20=E6=88=96=E7=A9=BA=20value?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../listener/notice/RocketMqMessagePushEventListener.java        | 1 +
 1 file changed, 1 insertion(+)

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 e09f3bed7..afaf42772 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
@@ -161,6 +161,7 @@ public class RocketMqMessagePushEventListener implements BpmnMessagePushEventLis
 
         BpmnProcessInstanceVO processInstance = getBpmnProcessInstanceVO(event);
         Map<String, Object> originVariables = processInstance.getVariables().entrySet().stream()
+                .filter(e -> Objects.nonNull(e.getKey()) && Objects.nonNull(e.getValue()))
                 .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
 
         BpmnTaskDelegateAssigner initiator = (BpmnTaskDelegateAssigner) originVariables.getOrDefault(INTERNAL_INITIATOR,