From 93e94be107ec8f6ec7215d1ebef9dc04e27b5c31 Mon Sep 17 00:00:00 2001
From: LeoLee <512240816@qq.com>
Date: Sat, 11 Dec 2021 22:00:26 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0put=E5=88=B0datamap=E7=9A=84v?=
 =?UTF-8?q?alue=E7=9A=84=E9=9D=9Enull=E5=88=A4=E6=96=AD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../yomahub/liteflow/entity/data/AbsSlot.java | 28 +++++++++++++++++++
 1 file changed, 28 insertions(+)

diff --git a/liteflow-core/src/main/java/com/yomahub/liteflow/entity/data/AbsSlot.java b/liteflow-core/src/main/java/com/yomahub/liteflow/entity/data/AbsSlot.java
index 10684c759..f7d080db3 100644
--- a/liteflow-core/src/main/java/com/yomahub/liteflow/entity/data/AbsSlot.java
+++ b/liteflow-core/src/main/java/com/yomahub/liteflow/entity/data/AbsSlot.java
@@ -77,6 +77,10 @@ public abstract class AbsSlot implements Slot {
 	}
 
 	public <T> void setRequestData(T t){
+		if (null == t) {
+			//data slot is a ConcurrentHashMap, so null value will trigger NullPointerException
+			throw new NullParamException("data slot can't accept null param");
+		}
 		dataMap.put(REQUEST, t);
 	}
 
@@ -85,6 +89,10 @@ public abstract class AbsSlot implements Slot {
 	}
 
 	public <T> void setResponseData(T t){
+		if (null == t) {
+			//data slot is a ConcurrentHashMap, so null value will trigger NullPointerException
+			throw new NullParamException("data slot can't accept null param");
+		}
 		dataMap.put(RESPONSE, t);
 	}
 
@@ -93,6 +101,10 @@ public abstract class AbsSlot implements Slot {
 	}
 
 	public <T> void setChainReqData(String chainId, T t) {
+		if (null == t) {
+			//data slot is a ConcurrentHashMap, so null value will trigger NullPointerException
+			throw new NullParamException("data slot can't accept null param");
+		}
 		dataMap.put(CHAIN_REQ_PREFIX + chainId, t);
 	}
 
@@ -105,6 +117,10 @@ public abstract class AbsSlot implements Slot {
 	}
 
 	public <T> void setData(String key, T t){
+		if (null == t) {
+			//data slot is a ConcurrentHashMap, so null value will trigger NullPointerException
+			throw new NullParamException("data slot can't accept null param");
+		}
 		dataMap.put(key, t);
 	}
 
@@ -133,6 +149,10 @@ public abstract class AbsSlot implements Slot {
 	}
 
 	public <T> void setCondResult(String key, T t){
+		if (null == t) {
+			//data slot is a ConcurrentHashMap, so null value will trigger NullPointerException
+			throw new NullParamException("data slot can't accept null param");
+		}
 		dataMap.put(COND_NODE_PREFIX + key, t);
 	}
 
@@ -141,6 +161,10 @@ public abstract class AbsSlot implements Slot {
 	}
 
 	public void setChainName(String chainName) {
+		if (null == chainName) {
+			//data slot is a ConcurrentHashMap, so null value will trigger NullPointerException
+			throw new NullParamException("data slot can't accept null param");
+		}
 		dataMap.put(CHAINNAME, chainName);
 	}
 
@@ -187,6 +211,10 @@ public abstract class AbsSlot implements Slot {
 
 	@Override
 	public void setException(Exception e) {
+		if (null == e) {
+			//data slot is a ConcurrentHashMap, so null value will trigger NullPointerException
+			throw new NullParamException("data slot can't accept null param");
+		}
 		this.dataMap.put(EXCEPTION, e);
 	}
 }