diff options
| author | jason | 2018-02-19 11:45:06 -0700 |
|---|---|---|
| committer | GitHub | 2018-02-19 11:45:06 -0700 |
| commit | fbbf4343a5a960d76632a7ed55608e71ed0394e0 (patch) | |
| tree | db332ddda4eff94fb58708c793ce682873ee576c | |
| parent | cbc63f6d36cda3d3ca5d59a0d6147688f4f3452c (diff) | |
| parent | 493efdc5533fef378116ad08581b1969c34d61c2 (diff) | |
| download | eventmq-fbbf4343a5a960d76632a7ed55608e71ed0394e0.tar.gz eventmq-fbbf4343a5a960d76632a7ed55608e71ed0394e0.zip | |
Merge pull request #59 from lindleywhite/master
Add arguments to the scheduler and router
| -rwxr-xr-x | bin/emq-router | 12 | ||||
| -rwxr-xr-x | bin/emq-scheduler | 11 |
2 files changed, 23 insertions, 0 deletions
diff --git a/bin/emq-router b/bin/emq-router index f10d8da..425a985 100755 --- a/bin/emq-router +++ b/bin/emq-router | |||
| @@ -1,8 +1,20 @@ | |||
| 1 | #!/usr/bin/env python | 1 | #!/usr/bin/env python |
| 2 | # -*- mode: python -*- | 2 | # -*- mode: python -*- |
| 3 | import argparse | ||
| 4 | |||
| 3 | from eventmq.log import setup_logger | 5 | from eventmq.log import setup_logger |
| 4 | from eventmq.router import Router | 6 | from eventmq.router import Router |
| 5 | 7 | ||
| 6 | if __name__ == "__main__": | 8 | if __name__ == "__main__": |
| 9 | parser = argparse.ArgumentParser( | ||
| 10 | description='Route job messages to their appropriate queues') | ||
| 11 | parser.add_argument('--config', '-C', type=str, nargs='?', | ||
| 12 | help='manually specify the location of eventmq.conf') | ||
| 13 | |||
| 14 | args = parser.parse_args() | ||
| 15 | |||
| 16 | if args.config: | ||
| 17 | conf.CONFIG_FILE = args.config | ||
| 18 | |||
| 7 | r = Router() | 19 | r = Router() |
| 8 | r.router_main() | 20 | r.router_main() |
diff --git a/bin/emq-scheduler b/bin/emq-scheduler index 106b6bf..31f7152 100755 --- a/bin/emq-scheduler +++ b/bin/emq-scheduler | |||
| @@ -1,7 +1,18 @@ | |||
| 1 | #!/usr/bin/env python | 1 | #!/usr/bin/env python |
| 2 | # -*- mode: python -*- | 2 | # -*- mode: python -*- |
| 3 | import argparse | ||
| 3 | from eventmq.scheduler import Scheduler | 4 | from eventmq.scheduler import Scheduler |
| 4 | 5 | ||
| 5 | if __name__ == "__main__": | 6 | if __name__ == "__main__": |
| 7 | parser = argparse.ArgumentParser( | ||
| 8 | description='Listen for scheduled jobs and run them') | ||
| 9 | parser.add_argument('--config', '-C', type=str, nargs='?', | ||
| 10 | help='manually specify the location of eventmq.conf') | ||
| 11 | |||
| 12 | args = parser.parse_args() | ||
| 13 | |||
| 14 | if args.config: | ||
| 15 | conf.CONFIG_FILE = args.config | ||
| 16 | |||
| 6 | s = Scheduler() | 17 | s = Scheduler() |
| 7 | s.scheduler_main() | 18 | s.scheduler_main() |