diff options
| author | jason | 2016-05-24 16:49:54 -0600 |
|---|---|---|
| committer | jason | 2016-05-24 16:49:54 -0600 |
| commit | a592ba06ea019bbb0051ffe5fc006d98560d038a (patch) | |
| tree | 588590a6423a19c59aa2cac9f57b7025f4f5f44b /etc | |
| parent | 2c599d965493b3658ffadc0c3e9e1b5a209cf1ba (diff) | |
| download | eventmq-a592ba06ea019bbb0051ffe5fc006d98560d038a.tar.gz eventmq-a592ba06ea019bbb0051ffe5fc006d98560d038a.zip | |
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.
Diffstat (limited to 'etc')
| -rw-r--r-- | etc/eventmq.docker.conf | 13 |
1 files changed, 10 insertions, 3 deletions
diff --git a/etc/eventmq.docker.conf b/etc/eventmq.docker.conf index a61364c..55fee92 100644 --- a/etc/eventmq.docker.conf +++ b/etc/eventmq.docker.conf | |||
| @@ -1,4 +1,10 @@ | |||
| 1 | [settings] | 1 | [global] |
| 2 | # Enable message output at different stages in the app. | ||
| 3 | super_debug = true | ||
| 4 | |||
| 5 | # Hide the heartbeat logs when super_debug is enabled. Showing them will generate a lot of messages. | ||
| 6 | hide_heartbeat_logs = True | ||
| 7 | |||
| 2 | frontend_addr=tcp://0.0.0.0:47291 | 8 | frontend_addr=tcp://0.0.0.0:47291 |
| 3 | backend_addr=tcp://0.0.0.0:47290 | 9 | backend_addr=tcp://0.0.0.0:47290 |
| 4 | worker_addr=tcp://eventmq:47290 | 10 | worker_addr=tcp://eventmq:47290 |
| @@ -9,5 +15,6 @@ scheduler_addr=tcp://eventmq:47291 | |||
| 9 | [scheduler] | 15 | [scheduler] |
| 10 | 16 | ||
| 11 | [jobmanager] | 17 | [jobmanager] |
| 12 | queues=one,two,three,default | 18 | worker_addr=tcp://127.0.0.1:47290 |
| 13 | worker_addr=tcp://127.0.0.1:47290 \ No newline at end of file | 19 | queues=[[50,"google"], [40,"pushes"], [10,"default"]] |
| 20 | concurrent_jobs=2 \ No newline at end of file | ||