More work for named queues

- Rename `WORKERS` setting to `CONCURRENT_JOBS` for more clarity. Added this
  setting to the command line options, the ini .conf & default settings conf.py
  files.
- Added support for JSON style arrays in INI config.
- Added support for weighted named queues. The style for the setting is
  [[weight, "name"], [weight, "name"]]. Configured in both the INI and command
  line for job manager. Added documentation.
- Updated the spec for the INFORM message. Weights are sent with the queue
  names. If there are no weights specified they will be given the default value
  of 0.
- updated Router.queues to a list from a deque so that it can be sorted
  by priority more easily.

1 files changed, 14 insertions, 4 deletions

diff --git a/bin/emq-jobmanager b/bin/emq-jobmanager
index 82c2e9b..4071ada 100755
--- a/bin/emq-jobmanager
+++ b/bin/emq-jobmanager
@@ -21,12 +21,19 @@ from eventmq.jobmanager import JobManager
 from eventmq import conf
 
 if __name__ == "__main__":
-    parser = argparse.ArgumentParser(description='Listen for requests')
-    parser.add_argument('--config', '-c', type=str, nargs='?',
+    parser = argparse.ArgumentParser(description='Listen for job requests and '
+                                     'manage their execution')
+    parser.add_argument('--broker-addr', '-B', type=str, nargs='?',
+                        help='manually specify the broker address to connect '
+                        'to in order to receive jobs')
+    parser.add_argument('--config', '-C', type=str, nargs='?',
                         help='manually specify the location of eventmq.conf')
     parser.add_argument('--queues', '-Q', type=str, nargs='+',
                         help='space separated list of queue names to listen '
                              'on')
+    parser.add_argument('--jobs', '-J', type=int, nargs='?',
+                        help='the max number of concurrent jobs to manage at '
+                        'a time')
 
     args = parser.parse_args()
 
@@ -39,5 +46,8 @@ if __name__ == "__main__":
     if queues:
         queues = ','.join(queues)
 
-    j = JobManager(queues=queues)
-    j.jobmanager_main()
+    broker_addr = args.broker_addr
+    concurrent_jobs = args.jobs
+
+    j = JobManager(queues=queues, concurrent_jobs=concurrent_jobs)
+    j.jobmanager_main(broker_addr=broker_addr)