aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorlwhite2018-02-19 11:38:29 -0700
committerlwhite2018-02-19 11:38:29 -0700
commit178b3ad7ce163f21761ba792e04e723ec1bf58be (patch)
tree8aafb3e1f11616dc4bbdb1bd4a7ded90caf09f2d
parentcbc63f6d36cda3d3ca5d59a0d6147688f4f3452c (diff)
downloadeventmq-178b3ad7ce163f21761ba792e04e723ec1bf58be.tar.gz
eventmq-178b3ad7ce163f21761ba792e04e723ec1bf58be.zip
Add config flags for the scheduler and router
-rwxr-xr-xbin/emq-router12
-rwxr-xr-xbin/emq-scheduler10
2 files changed, 22 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..eae99cf 100755
--- a/bin/emq-scheduler
+++ b/bin/emq-scheduler
@@ -3,5 +3,15 @@
3from eventmq.scheduler import Scheduler 3from eventmq.scheduler import Scheduler
4 4
5if __name__ == "__main__": 5if __name__ == "__main__":
6 parser = argparse.ArgumentParser(
7 description='Listen for scheduled jobs and run them')
8 parser.add_argument('--config', '-C', type=str, nargs='?',
9 help='manually specify the location of eventmq.conf')
10
11 args = parser.parse_args()
12
13 if args.config:
14 conf.CONFIG_FILE = args.config
15
6 s = Scheduler() 16 s = Scheduler()
7 s.scheduler_main() 17 s.scheduler_main()