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 2bc27f15598 Rename GlobalMetaDataChangedListener (#34250)
2bc27f15598 is described below

commit 2bc27f155983129094ac8b1055b19967be7abc59
Author: Liang Zhang <[email protected]>
AuthorDate: Sat Jan 4 23:55:27 2025 +0800

    Rename GlobalMetaDataChangedListener (#34250)
---
 .../cluster/dispatch/listener/DataChangedEventListenerRegistry.java   | 4 ++--
 ...MetaDataChangedHandler.java => GlobalMetaDataChangedListener.java} | 4 ++--
 .../dispatch/listener/DataChangedEventListenerRegistryTest.java       | 4 ++--
 3 files changed, 6 insertions(+), 6 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 d6d4fc460ef..715e4e1c2db 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
@@ -22,7 +22,7 @@ import 
org.apache.shardingsphere.metadata.persist.node.DatabaseMetaDataNode;
 import org.apache.shardingsphere.mode.manager.ContextManager;
 import 
org.apache.shardingsphere.mode.manager.cluster.dispatch.handler.DataChangedEventHandler;
 import 
org.apache.shardingsphere.mode.manager.cluster.dispatch.listener.type.DatabaseMetaDataChangedListener;
-import 
org.apache.shardingsphere.mode.manager.cluster.dispatch.listener.type.GlobalMetaDataChangedHandler;
+import 
org.apache.shardingsphere.mode.manager.cluster.dispatch.listener.type.GlobalMetaDataChangedListener;
 import 
org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepository;
 
 import java.util.Collection;
@@ -57,6 +57,6 @@ public final class DataChangedEventListenerRegistry {
     }
     
     private void registerGlobalHandlers(final DataChangedEventHandler handler) 
{
-        repository.watch(handler.getSubscribedKey(), new 
GlobalMetaDataChangedHandler(contextManager, handler));
+        repository.watch(handler.getSubscribedKey(), new 
GlobalMetaDataChangedListener(contextManager, handler));
     }
 }
diff --git 
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/type/GlobalMetaDataChangedHandler.java
 
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/type/GlobalMetaDataChangedListener.java
similarity index 93%
rename from 
mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/type/GlobalMetaDataChangedHandler.java
rename to 
mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/type/GlobalMetaDataChangedListener.java
index c067e6fa2f3..bd5e427f248 100644
--- 
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/type/GlobalMetaDataChangedHandler.java
+++ 
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/type/GlobalMetaDataChangedListener.java
@@ -25,10 +25,10 @@ import 
org.apache.shardingsphere.mode.manager.cluster.dispatch.handler.DataChang
 import 
org.apache.shardingsphere.mode.repository.cluster.listener.DataChangedEventListener;
 
 /**
- * Global meta data changed handler.
+ * Global meta data changed listener.
  */
 @RequiredArgsConstructor
-public final class GlobalMetaDataChangedHandler implements 
DataChangedEventListener {
+public final class GlobalMetaDataChangedListener implements 
DataChangedEventListener {
     
     private final ContextManager contextManager;
     
diff --git 
a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/DataChangedEventListenerRegistryTest.java
 
b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/DataChangedEventListenerRegistryTest.java
index 620aef5d8cf..206793f2071 100644
--- 
a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/DataChangedEventListenerRegistryTest.java
+++ 
b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/DataChangedEventListenerRegistryTest.java
@@ -19,7 +19,7 @@ package 
org.apache.shardingsphere.mode.manager.cluster.dispatch.listener;
 
 import org.apache.shardingsphere.mode.manager.ContextManager;
 import 
org.apache.shardingsphere.mode.manager.cluster.dispatch.listener.type.DatabaseMetaDataChangedListener;
-import 
org.apache.shardingsphere.mode.manager.cluster.dispatch.listener.type.GlobalMetaDataChangedHandler;
+import 
org.apache.shardingsphere.mode.manager.cluster.dispatch.listener.type.GlobalMetaDataChangedListener;
 import 
org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepository;
 import org.junit.jupiter.api.Test;
 
@@ -44,6 +44,6 @@ class DataChangedEventListenerRegistryTest {
         DataChangedEventListenerRegistry registry = new 
DataChangedEventListenerRegistry(contextManager, 
Collections.singleton("foo_db"));
         registry.register();
         verify(repository).watch(eq("/metadata/foo_db"), 
any(DatabaseMetaDataChangedListener.class));
-        verify(repository, atLeastOnce()).watch(anyString(), 
any(GlobalMetaDataChangedHandler.class));
+        verify(repository, atLeastOnce()).watch(anyString(), 
any(GlobalMetaDataChangedListener.class));
     }
 }

Reply via email to