This is an automated email from the ASF dual-hosted git repository.
duanzhengqiang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new 70bcee06edf Refactor NamingEventListener (#28050)
70bcee06edf is described below
commit 70bcee06edf299ac60090d8091a0ae46da949de3
Author: Liang Zhang <[email protected]>
AuthorDate: Sat Aug 12 14:46:55 2023 +0800
Refactor NamingEventListener (#28050)
---
.../mode/repository/cluster/nacos/listener/NamingEventListener.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/mode/type/cluster/repository/provider/nacos/src/main/java/org/apache/shardingsphere/mode/repository/cluster/nacos/listener/NamingEventListener.java
b/mode/type/cluster/repository/provider/nacos/src/main/java/org/apache/shardingsphere/mode/repository/cluster/nacos/listener/NamingEventListener.java
index bff18134f09..09516f5bce0 100644
---
a/mode/type/cluster/repository/provider/nacos/src/main/java/org/apache/shardingsphere/mode/repository/cluster/nacos/listener/NamingEventListener.java
+++
b/mode/type/cluster/repository/provider/nacos/src/main/java/org/apache/shardingsphere/mode/repository/cluster/nacos/listener/NamingEventListener.java
@@ -116,7 +116,8 @@ public final class NamingEventListener implements
EventListener {
}
}
return false;
- }).collect(Collectors.toMap(NacosMetaDataUtils::getKey,
Function.identity(), (a, b) -> NacosMetaDataUtils.getTimestamp(a) >
NacosMetaDataUtils.getTimestamp(b) ? a : b));
+ }).collect(Collectors.toMap(NacosMetaDataUtils::getKey,
Function.identity(),
+ (oldValue, currentValue) ->
NacosMetaDataUtils.getTimestamp(oldValue) >
NacosMetaDataUtils.getTimestamp(currentValue) ? oldValue : currentValue));
}
/**