Merge "Issue with port for RabbitMQ"
This commit is contained in:
commit
8da1505023
|
@ -17,7 +17,7 @@ log = logging.getLogger(__name__)
|
|||
class Controller(object):
|
||||
def __init__(self):
|
||||
self.write_lock = Semaphore(1)
|
||||
connection = amqp.Connection(rabbitmq.host, virtual_host=rabbitmq.virtual_host,
|
||||
connection = amqp.Connection('{0}:{1}'.format(rabbitmq.host, rabbitmq.port), virtual_host=rabbitmq.virtual_host,
|
||||
userid=rabbitmq.userid, password=rabbitmq.password,
|
||||
ssl=rabbitmq.use_ssl, insist=True)
|
||||
self.ch = connection.channel()
|
||||
|
|
|
@ -27,7 +27,7 @@ class TaskResultHandlerService(service.Service):
|
|||
super(TaskResultHandlerService, self).stop()
|
||||
|
||||
def _handle_results(self):
|
||||
connection = amqp.Connection(rabbitmq.host, virtual_host=rabbitmq.virtual_host,
|
||||
connection = amqp.Connection('{0}:{1}'.format(rabbitmq.host, rabbitmq.port), virtual_host=rabbitmq.virtual_host,
|
||||
userid=rabbitmq.userid, password=rabbitmq.password,
|
||||
ssl=rabbitmq.use_ssl, insist=True)
|
||||
ch = connection.channel()
|
||||
|
|
Loading…
Reference in New Issue