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));
     }
     
     /**

Reply via email to