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 <[email protected]>
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
