Removed references to old queus

This commit is contained in:
Martyn Inglis
2017-05-30 11:24:26 +01:00
parent f7e1ccea8b
commit d74675b6d8
2 changed files with 7 additions and 28 deletions

View File

@@ -24,23 +24,6 @@ class QueueNames(object):
NOTIFY = 'notify-internal-tasks'
PROCESS_FTP = 'process-ftp-tasks'
@staticmethod
def old_queues():
return [
'db-sms',
'db-email',
'db-letter',
'priority',
'periodic',
'send-sms',
'send-email',
'research-mode',
'statistics',
'notify',
'retry',
'process-job'
]
@staticmethod
def all_queues():
return [
@@ -262,8 +245,6 @@ class Development(Config):
NOTIFICATION_QUEUE_PREFIX = 'development'
DEBUG = True
queues = QueueNames.all_queues() + QueueNames.old_queues()
for queue in QueueNames.all_queues():
Config.CELERY_QUEUES.append(
Queue(queue, Exchange('default'), routing_key=queue)
@@ -283,9 +264,7 @@ class Test(Config):
STATSD_HOST = "localhost"
STATSD_PORT = 1000
queues = QueueNames.all_queues() + QueueNames.old_queues()
for queue in queues:
for queue in QueueNames.all_queues():
Config.CELERY_QUEUES.append(
Queue(queue, Exchange('default'), routing_key=queue)
)