From 6fa953ab0a13f01387eb277ee9846cd1d5bbd1dc Mon Sep 17 00:00:00 2001 From: yechuan Date: Tue, 15 Aug 2023 10:39:52 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A4=9A=E4=BD=99=E5=88=A4=E6=96=AD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- source/src/main/java/work/xuye/source/handler/SourceHandler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/src/main/java/work/xuye/source/handler/SourceHandler.java b/source/src/main/java/work/xuye/source/handler/SourceHandler.java index dd515fe..eba2fdb 100644 --- a/source/src/main/java/work/xuye/source/handler/SourceHandler.java +++ b/source/src/main/java/work/xuye/source/handler/SourceHandler.java @@ -127,7 +127,7 @@ public class SourceHandler { if (!ObjectUtils.isEmpty(nextNodeMessage)) { nextNodeMessage.forEach((k, v) -> { Set set = v.getHeaders().get(MessageConstants.OTHER_CACHE_KEY_SET, Set.class); - if (!ObjectUtils.isEmpty(set) && !ObjectUtils.isEmpty(otherCacheKeySet)) { + if (!ObjectUtils.isEmpty(set)) { set.addAll(otherCacheKeySet); v.getHeaders().put(MessageConstants.OTHER_CACHE_KEY_SET, set); }