stackforge-attic/murano-docs
Code Issues Proposed changes

Issue with port for RabbitMQ

Browse Source
This commit is contained in:
Serg Melikyan 2013-03-11 13:35:05 +04:00
parent 18bbb7c496
commit a2274f8c1d
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
portas/portas/api/v1/sessions.py
View File

@ -17,7 +17,7 @@ log = logging.getLogger(__name__)
class Controller(object): class Controller(object):
def __init__(self): def __init__(self):
self.write_lock = Semaphore(1) 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, userid=rabbitmq.userid, password=rabbitmq.password,
ssl=rabbitmq.use_ssl, insist=True) ssl=rabbitmq.use_ssl, insist=True)
self.ch = connection.channel() self.ch = connection.channel()

2
portas/portas/common/service.py
View File

@ -27,7 +27,7 @@ class TaskResultHandlerService(service.Service):
super(TaskResultHandlerService, self).stop() super(TaskResultHandlerService, self).stop()
def _handle_results(self): 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, userid=rabbitmq.userid, password=rabbitmq.password,
ssl=rabbitmq.use_ssl, insist=True) ssl=rabbitmq.use_ssl, insist=True)
ch = connection.channel() ch = connection.channel()