(shardingsphere) branch master updated: Refactor DataChangedEventListenerRegistry (#35073)

[zhangliang]

This is an automated email from the ASF dual-hosted git repository.

zhangliang 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 8d1940bdcd6 Refactor DataChangedEventListenerRegistry (#35073)
8d1940bdcd6 is described below

commit 8d1940bdcd60f6a01280b3d791bb2b85a34a6f02
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Tue Mar 25 14:15:16 2025 +0800

    Refactor DataChangedEventListenerRegistry (#35073)
---
 .../cluster/dispatch/listener/DataChangedEventListenerRegistry.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/DataChangedEventListenerRegistry.java
 
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/DataChangedEventListenerRegistry.java
index 8b309f81134..6126af252bd 100644
--- 
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/DataChangedEventListenerRegistry.java
+++ 
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/DataChangedEventListenerRegistry.java
@@ -50,14 +50,14 @@ public final class DataChangedEventListenerRegistry {
      */
     public void register() {
         databaseNames.forEach(this::registerDatabaseListeners);
-        
ShardingSphereServiceLoader.getServiceInstances(GlobalDataChangedEventHandler.class).forEach(this::registerGlobalHandlers);
+        
ShardingSphereServiceLoader.getServiceInstances(GlobalDataChangedEventHandler.class).forEach(this::registerGlobalListeners);
     }
     
     private void registerDatabaseListeners(final String databaseName) {
         repository.watch(NodePathGenerator.toPath(new 
DatabaseMetaDataNodePath(databaseName)), new 
DatabaseMetaDataChangedListener(contextManager));
     }
     
-    private void registerGlobalHandlers(final GlobalDataChangedEventHandler 
handler) {
+    private void registerGlobalListeners(final GlobalDataChangedEventHandler 
handler) {
         
repository.watch(NodePathGenerator.toPath(handler.getSubscribedNodePath()), new 
GlobalMetaDataChangedListener(contextManager, handler));
     }
 }