Refactor ProcessListChangedSubscriber

apache · Dec 29, 2024 · d1e6c60 · d1e6c60
1 parent 29c4dc2
commit d1e6c60
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...ere/mode/manager/cluster/event/dispatch/subscriber/type/ProcessListChangedSubscriber.java b/...ere/mode/manager/cluster/event/dispatch/subscriber/type/ProcessListChangedSubscriber.java
@@ -42,14 +42,14 @@
  */
 public final class ProcessListChangedSubscriber implements DispatchEventSubscriber {
 
-    private final ContextManager contextManager;
+    private final String instanceMetaDataId;
 
     private final PersistRepository repository;
 
     private final YamlProcessListSwapper swapper;
 
     public ProcessListChangedSubscriber(final ContextManager contextManager) {
-        this.contextManager = contextManager;
+        instanceMetaDataId = contextManager.getComputeNodeInstanceContext().getInstance().getMetaData().getId();
         repository = contextManager.getPersistServiceFacade().getRepository();
         swapper = new YamlProcessListSwapper();
     }
@@ -61,7 +61,7 @@ public ProcessListChangedSubscriber(final ContextManager contextManager) {
      */
     @Subscribe
     public void reportLocalProcesses(final ReportLocalProcessesEvent event) {
-        if (!event.getInstanceId().equals(contextManager.getComputeNodeInstanceContext().getInstance().getMetaData().getId())) {
+        if (!event.getInstanceId().equals(instanceMetaDataId)) {
             return;
         }
         Collection<Process> processes = ProcessRegistry.getInstance().listAll();
@@ -89,7 +89,7 @@ public synchronized void completeToReportLocalProcesses(final ReportLocalProcess
      */
     @Subscribe
     public synchronized void killLocalProcess(final KillLocalProcessEvent event) throws SQLException {
-        if (!event.getInstanceId().equals(contextManager.getComputeNodeInstanceContext().getInstance().getMetaData().getId())) {
+        if (!event.getInstanceId().equals(instanceMetaDataId)) {
             return;
         }
         Process process = ProcessRegistry.getInstance().get(event.getProcessId());