From 0169ebe69ada10b35fd1796204353b9e27d83588 Mon Sep 17 00:00:00 2001
From: Rebecca Law <rebecca.law@digital.cabinet-office.gov.uk>
Date: Wed, 2 Mar 2016 16:22:22 +0000
Subject: [PATCH] Add routing keys to celery queues.

NOTE: make sure upstart script on preview is updated before merging.
---
 config.py             | 10 ++++++++++
 scripts/run_celery.sh |  2 +-
 2 files changed, 11 insertions(+), 1 deletion(-)

diff --git a/config.py b/config.py
index cd98ed4ff..7237a2c07 100644
--- a/config.py
+++ b/config.py
@@ -43,6 +43,16 @@ class Config(object):
     #         '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',)
     TWILIO_ACCOUNT_SID = os.getenv('TWILIO_ACCOUNT_SID')
     TWILIO_AUTH_TOKEN = os.getenv('TWILIO_AUTH_TOKEN')
diff --git a/scripts/run_celery.sh b/scripts/run_celery.sh
index 1d2abbc8b..8b2a1dec2 100755
--- a/scripts/run_celery.sh
+++ b/scripts/run_celery.sh
@@ -3,4 +3,4 @@
 set -e
 
 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