Used lifecycle registration to register initialization mode
This commit is contained in:
+5
-5
@@ -1,6 +1,7 @@
|
|||||||
import threading
|
import threading
|
||||||
|
|
||||||
from core.server.server import startServer
|
from core.server.server import startServer
|
||||||
|
from core.execution.lifecyclemanager.lifecycleregistry import registerLifecycle
|
||||||
from core.execution.createthread import buildThread
|
from core.execution.createthread import buildThread
|
||||||
from plugins.rmass.monitors import rmassmonitor
|
from plugins.rmass.monitors import rmassmonitor
|
||||||
from plugins.rmass.actions import refresh_tokens
|
from plugins.rmass.actions import refresh_tokens
|
||||||
@@ -8,15 +9,14 @@ from plugins.rmass.actions import refresh_tokens
|
|||||||
import login
|
import login
|
||||||
import synapsemessagepush
|
import synapsemessagepush
|
||||||
|
|
||||||
lifecycles ={}
|
lifecycles = {}
|
||||||
|
|
||||||
|
mode = "continuous"
|
||||||
|
|
||||||
lifecycles[rmassmonitor.name] = {}
|
lifecycles = registerLifecycle(rmassmonitor, lifecycles, "mode", mode)
|
||||||
lifecycles[rmassmonitor.name]["mode"] = "continuous"
|
|
||||||
thread, lifecycles = buildThread(rmassmonitor, lifecycles)
|
thread, lifecycles = buildThread(rmassmonitor, lifecycles)
|
||||||
|
|
||||||
lifecycles[refresh_tokens.name] = {}
|
lifecycles = registerLifecycle(refresh_tokens, lifecycles, "mode", mode)
|
||||||
lifecycles[refresh_tokens.name]["mode"] = "continuous"
|
|
||||||
thread, lifecycles = buildThread(refresh_tokens, lifecycles)
|
thread, lifecycles = buildThread(refresh_tokens, lifecycles)
|
||||||
|
|
||||||
thread = threading.Thread(
|
thread = threading.Thread(
|
||||||
|
|||||||
Reference in New Issue
Block a user