aboutsummaryrefslogtreecommitdiffstats
path: root/bin
diff options
context:
space:
mode:
Diffstat (limited to 'bin')
-rwxr-xr-xbin/emq-router13
-rwxr-xr-xbin/emq-scheduler13
2 files changed, 14 insertions, 12 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 @@
3import argparse 3import argparse
4 4
5from eventmq.log import setup_logger 5from eventmq.log import setup_logger
6from eventmq import conf
6from eventmq.router import Router 7from eventmq.router import Router
7 8
8if __name__ == "__main__": 9if __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()
diff --git a/bin/emq-scheduler b/bin/emq-scheduler
index 31f7152..3286c63 100755
--- a/bin/emq-scheduler
+++ b/bin/emq-scheduler
@@ -1,18 +1,19 @@
1#!/usr/bin/env python 1#!/usr/bin/env python
2# -*- mode: python -*- 2# -*- mode: python -*-
3import argparse 3import argparse
4from eventmq import conf
4from eventmq.scheduler import Scheduler 5from eventmq.scheduler import Scheduler
5 6
6if __name__ == "__main__": 7if __name__ == "__main__":
7 parser = argparse.ArgumentParser( 8 parser = argparse.ArgumentParser(
8 description='Listen for scheduled jobs and run them') 9 description='Listen for scheduled jobs and run them')
9 parser.add_argument('--config', '-C', type=str, nargs='?', 10 parser.add_argument('--config', '-C', type=str, nargs='?',
10 help='manually specify the location of eventmq.conf') 11 help='manually specify the location of eventmq.conf')
11 12
12 args = parser.parse_args() 13 args = parser.parse_args()
13 14
14 if args.config: 15 if args.config:
15 conf.CONFIG_FILE = args.config 16 conf.CONFIG_FILE = args.config
16 17
17 s = Scheduler() 18 s = Scheduler()
18 s.scheduler_main() 19 s.scheduler_main()