aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorlwhite2018-02-19 11:38:29 -0700
committerlwhite2018-02-19 11:39:49 -0700
commit6beb242f571b9fe01cc2882635db65c12ee3b5e2 (patch)
treedb332ddda4eff94fb58708c793ce682873ee576c
parentcbc63f6d36cda3d3ca5d59a0d6147688f4f3452c (diff)
downloadeventmq-6beb242f571b9fe01cc2882635db65c12ee3b5e2.tar.gz
eventmq-6beb242f571b9fe01cc2882635db65c12ee3b5e2.zip
Add config flags for the scheduler and router
-rwxr-xr-xbin/emq-router12
-rwxr-xr-xbin/emq-scheduler11
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 -*-
3import argparse
4
3from eventmq.log import setup_logger 5from eventmq.log import setup_logger
4from eventmq.router import Router 6from eventmq.router import Router
5 7
6if __name__ == "__main__": 8if __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 -*-
3import argparse
3from eventmq.scheduler import Scheduler 4from eventmq.scheduler import Scheduler
4 5
5if __name__ == "__main__": 6if __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()