Refactor usage of ContextManagerLifecycleListener.onInitialized

terrymanu · terrymanu · commit 98233773949b · 2025-03-16T23:16:39.000+08:00
diff --git a/mode/core/src/main/java/org/apache/shardingsphere/mode/manager/ContextManager.java b/mode/core/src/main/java/org/apache/shardingsphere/mode/manager/ContextManager.java
@@ -81,7 +81,7 @@ public ContextManager(final MetaDataContexts metaDataContexts, final ComputeNode
         stateContext = new StateContext(persistServiceFacade.getStateService().load());
         executorEngine = ExecutorEngine.createExecutorEngineWithSize(metaDataContexts.getMetaData().getProps().<Integer>getValue(ConfigurationPropertyKey.KERNEL_EXECUTOR_SIZE));
         for (ContextManagerLifecycleListener each : ShardingSphereServiceLoader.getServiceInstances(ContextManagerLifecycleListener.class)) {
-            if (this.getComputeNodeInstanceContext().getModeConfiguration().isCluster()) {
+            if (computeNodeInstanceContext.getModeConfiguration().isCluster()) {
                 each.onInitialized(this);
             }
         }

Original file line number	Diff line number	Diff line change
`@@ -81,7 +81,7 @@ public ContextManager(final MetaDataContexts metaDataContexts, final ComputeNode`
`81`	`81`	`stateContext = new StateContext(persistServiceFacade.getStateService().load());`
`82`	`82`	`executorEngine = ExecutorEngine.createExecutorEngineWithSize(metaDataContexts.getMetaData().getProps().<Integer>getValue(ConfigurationPropertyKey.KERNEL_EXECUTOR_SIZE));`
`83`	`83`	`for (ContextManagerLifecycleListener each : ShardingSphereServiceLoader.getServiceInstances(ContextManagerLifecycleListener.class)) {`
`84`		`- if (this.getComputeNodeInstanceContext().getModeConfiguration().isCluster()) {`
	`84`	`+ if (computeNodeInstanceContext.getModeConfiguration().isCluster()) {`
`85`	`85`	`each.onInitialized(this);`
`86`	`86`	`}`
`87`	`87`	`}`