You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by zh...@apache.org on 2024/08/25 12:33:50 UTC
(shardingsphere) branch master updated: Refactor ClusterDeliverEventSubscriberRegistry (#32672)
This is an automated email from the ASF dual-hosted git repository.
zhaojinchao 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 16948a79e67 Refactor ClusterDeliverEventSubscriberRegistry (#32672)
16948a79e67 is described below
commit 16948a79e67e9c5983280999a5267271aa18b984
Author: Liang Zhang <zh...@apache.org>
AuthorDate: Sun Aug 25 20:33:44 2024 +0800
Refactor ClusterDeliverEventSubscriberRegistry (#32672)
---
.../subscriber/registry/ClusterDeliverEventSubscriberRegistry.java | 2 +-
.../subscriber/registry/ClusterDispatchEventSubscriberRegistry.java | 6 +++---
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/registry/ClusterDeliverEventSubscriberRegistry.java b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/registry/ClusterDeliverEventSubscriberRegistry.java
index 2600f22aeb9..8ef25246e0e 100644
--- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/registry/ClusterDeliverEventSubscriberRegistry.java
+++ b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/registry/ClusterDeliverEventSubscriberRegistry.java
@@ -25,7 +25,7 @@ import org.apache.shardingsphere.mode.event.subsciber.DeliverEventSubscriberRegi
/**
* Cluster deliver event subscriber registry.
*/
-public class ClusterDeliverEventSubscriberRegistry extends DeliverEventSubscriberRegistry {
+public final class ClusterDeliverEventSubscriberRegistry extends DeliverEventSubscriberRegistry {
public ClusterDeliverEventSubscriberRegistry(final ContextManager contextManager) {
super(contextManager, new DeliverQualifiedDataSourceSubscriber((ClusterPersistRepository) contextManager.getPersistServiceFacade().getRepository()));
diff --git a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/registry/ClusterDispatchEventSubscriberRegistry.java b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/registry/ClusterDispatchEventSubscriberRegistry.java
index 0ecca9abd6a..b767575a715 100644
--- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/registry/ClusterDispatchEventSubscriberRegistry.java
+++ b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/subscriber/registry/ClusterDispatchEventSubscriberRegistry.java
@@ -40,7 +40,7 @@ import java.util.Collection;
/**
* Cluster dispatch event subscriber registry.
*/
-public class ClusterDispatchEventSubscriberRegistry implements EventSubscriberRegistry {
+public final class ClusterDispatchEventSubscriberRegistry implements EventSubscriberRegistry {
private final EventBusContext eventBusContext;
@@ -58,8 +58,8 @@ public class ClusterDispatchEventSubscriberRegistry implements EventSubscriberRe
new ComputeNodeOnlineSubscriber(contextManager),
new QualifiedDataSourceSubscriber(contextManager),
new StorageUnitEventSubscriber(contextManager),
- new GlobalRuleConfigurationEventSubscriber(contextManager),
- new PropertiesEventSubscriber(contextManager));
+ new PropertiesEventSubscriber(contextManager),
+ new GlobalRuleConfigurationEventSubscriber(contextManager));
}
@Override