diff options
| -rw-r--r-- | eventmq/jobmanager.py | 5 | ||||
| -rw-r--r-- | eventmq/router.py | 12 |
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 | ||
| 300 | def jobmanager_main(): | ||
| 301 | j = JobManager() | ||
| 302 | j.jobmanager_main() | ||
| 303 | |||
| 304 | |||
| 300 | def jobmanager_main(self): | 305 | def 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 | ||
| 399 | def 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 |