diff options
Diffstat (limited to 'bin/emq-router')
| -rwxr-xr-x | bin/emq-router | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/bin/emq-router b/bin/emq-router index 425a985..e6448e8 100755 --- a/bin/emq-router +++ b/bin/emq-router | |||
| @@ -3,18 +3,19 @@ | |||
| 3 | import argparse | 3 | import argparse |
| 4 | 4 | ||
| 5 | from eventmq.log import setup_logger | 5 | from eventmq.log import setup_logger |
| 6 | from eventmq import conf | ||
| 6 | from eventmq.router import Router | 7 | from eventmq.router import Router |
| 7 | 8 | ||
| 8 | if __name__ == "__main__": | 9 | if __name__ == "__main__": |
| 9 | parser = argparse.ArgumentParser( | 10 | parser = argparse.ArgumentParser( |
| 10 | description='Route job messages to their appropriate queues') | 11 | description='Route job messages to their appropriate queues') |
| 11 | parser.add_argument('--config', '-C', type=str, nargs='?', | 12 | parser.add_argument('--config', '-C', type=str, nargs='?', |
| 12 | help='manually specify the location of eventmq.conf') | 13 | help='manually specify the location of eventmq.conf') |
| 13 | 14 | ||
| 14 | args = parser.parse_args() | 15 | args = parser.parse_args() |
| 15 | 16 | ||
| 16 | if args.config: | 17 | if args.config: |
| 17 | conf.CONFIG_FILE = args.config | 18 | conf.CONFIG_FILE = args.config |
| 18 | 19 | ||
| 19 | r = Router() | 20 | r = Router() |
| 20 | r.router_main() | 21 | r.router_main() |