aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--eventmq/jobmanager.py5
-rw-r--r--eventmq/router.py12
2 files changed, 15 insertions, 2 deletions
diff --git a/eventmq/jobmanager.py b/eventmq/jobmanager.py
index 07cd2a6..b52eebd 100644
--- a/eventmq/jobmanager.py
+++ b/eventmq/jobmanager.py
@@ -297,6 +297,11 @@ class JobManager(HeartbeatMixin):
297 self.start(addr=conf.WORKER_ADDR) 297 self.start(addr=conf.WORKER_ADDR)
298 298
299 299
300def jobmanager_main():
301 j = JobManager()
302 j.jobmanager_main()
303
304
300def jobmanager_main(self): 305def jobmanager_main(self):
301 j = JobManager() 306 j = JobManager()
302 j.jobmanager_main() 307 j.jobmanager_main()
diff --git a/eventmq/router.py b/eventmq/router.py
index a858d3d..ac230ff 100644
--- a/eventmq/router.py
+++ b/eventmq/router.py
@@ -382,7 +382,8 @@ class Router(HeartbeatMixin):
382 self.incoming.unbind(conf.FRONTEND_ADDR) 382 self.incoming.unbind(conf.FRONTEND_ADDR)
383 self.outgoing.unbind(conf.BACKEND_ADDR) 383 self.outgoing.unbind(conf.BACKEND_ADDR)
384 import_settings() 384 import_settings()
385 self.start() 385 self.start(frontend_addr=conf.FRONTEND_ADDR,
386 backend_addr=conf.BACKEND_ADDR)
386 387
387 def router_main(self): 388 def router_main(self):
388 """ 389 """
@@ -390,7 +391,14 @@ class Router(HeartbeatMixin):
390 """ 391 """
391 setup_logger('eventmq') 392 setup_logger('eventmq')
392 import_settings() 393 import_settings()
393 self.start() 394 self.start(frontend_addr=conf.FRONTEND_ADDR,
395 backend_addr=conf.BACKEND_ADDR)
396
397
398# Entry point for pip console scripts
399def router_main():
400 r = Router()
401 r.router_main()
394 402
395 403
396# Entry point for pip console scripts 404# Entry point for pip console scripts