diff --git a/src/main/java/com/bellmann/runner/InterfaceService.java b/src/main/java/com/bellmann/runner/InterfaceService.java new file mode 100644 index 0000000..eef138a --- /dev/null +++ b/src/main/java/com/bellmann/runner/InterfaceService.java @@ -0,0 +1,49 @@ +package com.bellmann.runner; + + +import com.zznode.cap.api.CAP; +import com.zznode.cap.api.ServiceManager; +import com.zznode.itms.api.ACSManager; +import com.zznode.itms.api.InventoryManager; +import com.zznode.itms.api.NBIManager; +import com.zznode.itms.api.OAMManager; +import lombok.Getter; + + +public class InterfaceService extends ServiceManager { + static InterfaceService service = null; + + //任务超时的时间 + @Getter + private static String task_timeOut; + + public InterfaceService(String[] args) { + super(args); + } + @Override + public boolean init() { + CAP.trDebug("Start init service INTERFACE"); + if (!super.init()) { + CAP.trError("Failed to init QUERYService."); + return false; + } + service = this; + task_timeOut = getStringValueByName("TaskTimeOut"); + ACSManager.init(getStringValueByName("Service.Name.ACSManager")); + NBIManager.init(getStringValueByName("Service.Name.NBI")); + InventoryManager.init(getStringValueByName("Service.Name.Inventory")); + OAMManager.init(getStringValueByName("Service.Name.OAM")); + return true; + } + + + public synchronized static InterfaceService getInstance(){ + if(service != null){ + return service; + } + String[] arg = new String[] { "-ServerName", "INTERFACE" }; + service = new InterfaceService(arg); + return service; + } + +} diff --git a/src/main/java/com/bellmann/runner/ServiceManagerRunner.java b/src/main/java/com/bellmann/runner/ServiceManagerRunner.java new file mode 100644 index 0000000..c7137fa --- /dev/null +++ b/src/main/java/com/bellmann/runner/ServiceManagerRunner.java @@ -0,0 +1,24 @@ +package com.bellmann.runner; + +import lombok.extern.log4j.Log4j2; +import org.springframework.boot.ApplicationArguments; +import org.springframework.boot.ApplicationRunner; +import org.springframework.core.annotation.Order; +import org.springframework.stereotype.Component; + +@Component +@Order(value = 1) +@Log4j2 +public class ServiceManagerRunner implements ApplicationRunner { + + @Override + public void run(ApplicationArguments args) { + new Thread("ServiceManager") { + @Override + public void run() { + InterfaceService.getInstance().start(); + } + }.start(); + log.info("ServiceManager started"); + } +}