This commit is contained in:
Stan Lagun 2013-03-27 21:36:02 +04:00
parent 8c2bf8bfe0
commit 600e161f6c

View File

@ -79,7 +79,7 @@ class ConductorWorkflowService(service.Service):
with rabbitmq.RmqClient() as rmq:
rmq.declare('tasks', 'tasks')
rmq.declare('task-results')
with rmq.open('tasks2') as subscription:
with rmq.open('tasks') as subscription:
while True:
msg = subscription.get_message()
self.tg.add_thread(