1
0
AE86 1 жил өмнө
parent
commit
6e96cd023f

+ 8 - 1
dbsyncer-manager/src/main/java/org/dbsyncer/manager/ManagerFactory.java

@@ -1,9 +1,11 @@
 package org.dbsyncer.manager;
 
+import org.dbsyncer.manager.event.ClosedEvent;
 import org.dbsyncer.parser.ProfileComponent;
 import org.dbsyncer.parser.enums.MetaEnum;
 import org.dbsyncer.parser.model.Mapping;
 import org.dbsyncer.parser.model.Meta;
+import org.springframework.context.ApplicationListener;
 import org.springframework.stereotype.Component;
 import org.springframework.util.Assert;
 
@@ -17,7 +19,7 @@ import java.util.Map;
  * @date 2019/9/16 23:59
  */
 @Component
-public class ManagerFactory {
+public class ManagerFactory implements ApplicationListener<ClosedEvent> {
 
     @Resource
     private ProfileComponent profileComponent;
@@ -25,6 +27,11 @@ public class ManagerFactory {
     @Resource
     private Map<String, Puller> map;
 
+    @Override
+    public void onApplicationEvent(ClosedEvent event) {
+        changeMetaState(event.getMetaId(), MetaEnum.READY);
+    }
+
     public void start(Mapping mapping) {
         Puller puller = getPuller(mapping);
 

+ 0 - 29
dbsyncer-manager/src/main/java/org/dbsyncer/manager/listener/ClosedTaskListener.java

@@ -1,29 +0,0 @@
-/**
- * DBSyncer Copyright 2020-2023 All Rights Reserved.
- */
-package org.dbsyncer.manager.listener;
-
-import org.dbsyncer.manager.event.ClosedEvent;
-import org.dbsyncer.manager.ManagerFactory;
-import org.dbsyncer.parser.enums.MetaEnum;
-import org.springframework.context.ApplicationListener;
-import org.springframework.stereotype.Component;
-
-import javax.annotation.Resource;
-
-/**
- * @Version 1.0.0
- * @Author AE86
- * @Date 2023-11-14 01:48
- */
-@Component
-public class ClosedTaskListener implements ApplicationListener<ClosedEvent> {
-
-    @Resource
-    private ManagerFactory managerFactory;
-
-    @Override
-    public void onApplicationEvent(ClosedEvent event) {
-        managerFactory.changeMetaState(event.getMetaId(), MetaEnum.READY);
-    }
-}