diff options
| author | sideshowdave7 | 2016-01-08 13:35:14 -0700 |
|---|---|---|
| committer | sideshowdave7 | 2016-01-08 13:35:14 -0700 |
| commit | 7a60c6e8cb324155aedde34fc7b679ed0248ecc6 (patch) | |
| tree | 6061a8dd0557eb2738ae10967962e85b70debcc7 /bin | |
| parent | 010cb96df50dcbca80fbf1c9c32eea9d86d51447 (diff) | |
| download | eventmq-7a60c6e8cb324155aedde34fc7b679ed0248ecc6.tar.gz eventmq-7a60c6e8cb324155aedde34fc7b679ed0248ecc6.zip | |
MAN-29 Create a better config system for eventmq
Diffstat (limited to 'bin')
| -rwxr-xr-x | bin/router | 3 | ||||
| -rwxr-xr-x | bin/scheduler | 4 | ||||
| -rwxr-xr-x | bin/worker | 4 |
3 files changed, 3 insertions, 8 deletions
| @@ -4,6 +4,5 @@ from eventmq.log import setup_logger | |||
| 4 | from eventmq.router import Router | 4 | from eventmq.router import Router |
| 5 | 5 | ||
| 6 | if __name__ == "__main__": | 6 | if __name__ == "__main__": |
| 7 | setup_logger('eventmq') | ||
| 8 | r = Router() | 7 | r = Router() |
| 9 | r.start() | 8 | r.router_main() |
diff --git a/bin/scheduler b/bin/scheduler index 33f164e..106b6bf 100755 --- a/bin/scheduler +++ b/bin/scheduler | |||
| @@ -1,9 +1,7 @@ | |||
| 1 | #!/usr/bin/env python | 1 | #!/usr/bin/env python |
| 2 | # -*- mode: python -*- | 2 | # -*- mode: python -*- |
| 3 | from eventmq.log import setup_logger | ||
| 4 | from eventmq.scheduler import Scheduler | 3 | from eventmq.scheduler import Scheduler |
| 5 | 4 | ||
| 6 | if __name__ == "__main__": | 5 | if __name__ == "__main__": |
| 7 | setup_logger("eventmq") | ||
| 8 | s = Scheduler() | 6 | s = Scheduler() |
| 9 | s.start() | 7 | s.scheduler_main() |
| @@ -1,9 +1,7 @@ | |||
| 1 | #!/usr/bin/env python | 1 | #!/usr/bin/env python |
| 2 | # -*- mode: python -*- | 2 | # -*- mode: python -*- |
| 3 | from eventmq.jobmanager import JobManager | 3 | from eventmq.jobmanager import JobManager |
| 4 | from eventmq.log import setup_logger | ||
| 5 | 4 | ||
| 6 | if __name__ == "__main__": | 5 | if __name__ == "__main__": |
| 7 | setup_logger('') | ||
| 8 | j = JobManager() | 6 | j = JobManager() |
| 9 | j.start() | 7 | j.jobmanager_main() |