darkhelm/notifications-api
1
0
Fork 0
mirror of https://github.com/GSA/notifications-api.git synced 2026-02-01 15:46:07 -05:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #116 from alphagov/queues-defined-in-config

Browse Source 
Moved the deinition of which queues the worker will consume from
This commit is contained in:
Rebecca Law
2016-03-02 09:21:29 +00:00
parent a2b1dc0432 3872ac5e67
commit f1cf4eddd5
2 changed files with 12 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
config.py
View File

@@ -1,3 +1,4 @@
from kombu import Exchange, Queue
import os import os
@@ -48,6 +49,16 @@ class Config(object):
TWILIO_NUMBER = os.getenv('TWILIO_NUMBER') TWILIO_NUMBER = os.getenv('TWILIO_NUMBER')
FIRETEXT_NUMBER = os.getenv('FIRETEXT_NUMBER') FIRETEXT_NUMBER = os.getenv('FIRETEXT_NUMBER')
FIRETEXT_API_KEY = os.getenv("FIRETEXT_API_KEY") FIRETEXT_API_KEY = os.getenv("FIRETEXT_API_KEY")
CELERY_QUEUES = [
Queue('sms', Exchange('default'), routing_key='default'),
Queue('email', Exchange('default'), routing_key='default'),
Queue('sms-code', Exchange('default'), routing_key='default'),
Queue('email-code', Exchange('default'), routing_key='default'),
Queue('process-job', Exchange('default'), routing_key='default'),
Queue('bulk-sms', Exchange('default'), routing_key='default'),
Queue('bulk-email', Exchange('default'), routing_key='default'),
Queue('email-invited-user', Exchange('default'), routing_key='default')
]
class Development(Config): class Development(Config):

2
scripts/run_celery.sh
View File

@@ -3,4 +3,4 @@
set -e set -e
source environment.sh source environment.sh
celery -A run_celery.notify_celery worker --loglevel=INFO --concurrency=4 -Q sms,sms-code,email-code,email,process-job,bulk-sms,bulk-email,email-invited-user celery -A run_celery.notify_celery worker --loglevel=INFO --concurrency=4