aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorjason2018-02-19 15:42:02 -0700
committerGitHub2018-02-19 15:42:02 -0700
commit61550680b8159c38bec7ef3596360faf6da3d367 (patch)
tree743f3670ec9f9e28d9b0a36c90096adf7594b50b
parentecc2a0df93fc49b12b41afb8fd31615da6d3e5f5 (diff)
parent65bddb26d8b3171bb098f5b9c809ee1a867826ed (diff)
downloadeventmq-61550680b8159c38bec7ef3596360faf6da3d367.tar.gz
eventmq-61550680b8159c38bec7ef3596360faf6da3d367.zip
Merge pull request #60 from lindleywhite/master
Remove tabs, and add conf file
-rwxr-xr-xbin/emq-router13
-rwxr-xr-xbin/emq-scheduler13
-rw-r--r--eventmq/__init__.py2
-rw-r--r--setup.py2
4 files changed, 16 insertions, 14 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()
diff --git a/eventmq/__init__.py b/eventmq/__init__.py
index 7401a56..aefc3a2 100644
--- a/eventmq/__init__.py
+++ b/eventmq/__init__.py
@@ -1,5 +1,5 @@
1__author__ = 'EventMQ Contributors' 1__author__ = 'EventMQ Contributors'
2__version__ = '0.3.5.4' 2__version__ = '0.3.5.6'
3 3
4PROTOCOL_VERSION = 'eMQP/1.0' 4PROTOCOL_VERSION = 'eMQP/1.0'
5 5
diff --git a/setup.py b/setup.py
index e1d83c8..64afbd9 100644
--- a/setup.py
+++ b/setup.py
@@ -7,7 +7,7 @@ from setuptools import find_packages, setup
7 7
8setup( 8setup(
9 name='eventmq', 9 name='eventmq',
10 version='0.3.5.4', 10 version='0.3.5.6',
11 description='EventMQ job execution and messaging system based on ZeroMQ', 11 description='EventMQ job execution and messaging system based on ZeroMQ',
12 packages=find_packages(), 12 packages=find_packages(),
13 install_requires=['pyzmq==15.4.0', 13 install_requires=['pyzmq==15.4.0',