routing key should be the queue name rather than exchange name

This commit is contained in:
Jeff Bryner 2015-01-16 09:17:15 -08:00
Родитель 91055b3f3e
Коммит e110cc1104
1 изменённых файлов: 1 добавлений и 1 удалений

Просмотреть файл

@ -124,7 +124,7 @@ class AlertTask(Task):
max_retries=10)
ensurePublish(alertDict,
exchange=self.alertExchange,
routing_key=RABBITMQ['alertexchange'])
routing_key=RABBITMQ['alertqueue'])
self.log.debug('alert sent to the alert queue')
except Exception as e:
self.log.error('Exception while sending alert to message queue: {0}'.format(e))