|
|
@@ -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); |
|
|
|
} |
|
|
|