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

Merge pull request #123 from alphagov/add-routing-keys

Browse Source 
Add routing keys to celery queues.
This commit is contained in:
NIcholas Staples
2016-03-02 16:30:08 +00:00
parent 3fd3aa5b3e 0169ebe69a
commit ce7e0cef7a
2 changed files with 11 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
config.py
View File

@@ -43,6 +43,16 @@ class Config(object):
# 'schedule': timedelta(seconds=5) # 'schedule': timedelta(seconds=5)
# } # }
# } # }
CELERY_QUEUES = [
Queue('sms', Exchange('default'), routing_key='sms'),
Queue('email', Exchange('default'), routing_key='email'),
Queue('sms-code', Exchange('default'), routing_key='sms-code'),
Queue('email-code', Exchange('default'), routing_key='email-code'),
Queue('process-job', Exchange('default'), routing_key='process-job'),
Queue('bulk-sms', Exchange('default'), routing_key='bulk-sms'),
Queue('bulk-email', Exchange('default'), routing_key='bulk-email'),
Queue('email-invited-user', Exchange('default'), routing_key='email-invited-user')
]
CELERY_IMPORTS = ('app.celery.tasks',) CELERY_IMPORTS = ('app.celery.tasks',)
TWILIO_ACCOUNT_SID = os.getenv('TWILIO_ACCOUNT_SID') TWILIO_ACCOUNT_SID = os.getenv('TWILIO_ACCOUNT_SID')
TWILIO_AUTH_TOKEN = os.getenv('TWILIO_AUTH_TOKEN') TWILIO_AUTH_TOKEN = os.getenv('TWILIO_AUTH_TOKEN')

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