From 6744a891678a7c4f45ff62a0d0659a57ed25c7d3 Mon Sep 17 00:00:00 2001 From: zhangliang Date: Sat, 4 Jan 2025 23:51:53 +0800 Subject: [PATCH] Rename GlobalMetaDataChangedListener --- .../dispatch/listener/DataChangedEventListenerRegistry.java | 4 ++-- ...ChangedHandler.java => GlobalMetaDataChangedListener.java} | 4 ++-- .../listener/DataChangedEventListenerRegistryTest.java | 4 ++-- 3 files changed, 6 insertions(+), 6 deletions(-) rename mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/type/{GlobalMetaDataChangedHandler.java => GlobalMetaDataChangedListener.java} (93%) 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 d6d4fc460ef11..715e4e1c2db47 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.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 @@ private void registerDatabaseListeners(final String databaseName) { } 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 c067e6fa2f361..bd5e427f24872 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.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 620aef5d8cf5f..206793f20710e 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 @@ 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 @@ void assertRegister() { 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)); } }