From c91b15c2f90f670f2e3534ff13ead3c9c4d30250 Mon Sep 17 00:00:00 2001 From: zhangliang Date: Wed, 1 Jan 2025 23:24:49 +0800 Subject: [PATCH] Remove useless DispatchEvent --- .../dispatch/listener/DataChangedEventListenerRegistry.java | 4 ---- 1 file changed, 4 deletions(-) diff --git a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/dispatch/listener/DataChangedEventListenerRegistry.java b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/dispatch/listener/DataChangedEventListenerRegistry.java index 4017ce828e773..cea875543658c 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/dispatch/listener/DataChangedEventListenerRegistry.java +++ b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/event/dispatch/listener/DataChangedEventListenerRegistry.java @@ -18,7 +18,6 @@ package org.apache.shardingsphere.mode.manager.cluster.event.dispatch.listener; import org.apache.shardingsphere.infra.spi.ShardingSphereServiceLoader; -import org.apache.shardingsphere.infra.util.eventbus.EventBusContext; import org.apache.shardingsphere.metadata.persist.node.DatabaseMetaDataNode; import org.apache.shardingsphere.mode.manager.ContextManager; import org.apache.shardingsphere.mode.manager.cluster.event.dispatch.handler.DataChangedEventHandler; @@ -37,14 +36,11 @@ public final class DataChangedEventListenerRegistry { private final ClusterPersistRepository repository; - private final EventBusContext eventBusContext; - private final Collection databaseNames; public DataChangedEventListenerRegistry(final ContextManager contextManager, final Collection databaseNames) { this.contextManager = contextManager; repository = (ClusterPersistRepository) contextManager.getPersistServiceFacade().getRepository(); - eventBusContext = contextManager.getComputeNodeInstanceContext().getEventBusContext(); this.databaseNames = databaseNames; }