openstack
/
murano
Code Issues Proposed changes

Enable HA on declared queues 

Change-Id: I57a7ca13580a507f7a51c0ec7078f7f2eaef185e
This commit is contained in:
Serg Melikyan 2013-11-22 18:04:27 +04:00
parent 07bf9ab166
commit 494bcc5211
4 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
muranoapi/common/service.py
View File

@ -55,7 +55,8 @@ class TaskResultHandlerService(service.Service):
while True:
try:
with self._create_mq_client() as mqClient:
mqClient.declare(conf.results_exchange, conf.results_queue)
mqClient.declare(conf.results_exchange, conf.results_queue,
enable_ha=True)
with mqClient.open(conf.results_queue,
prefetch_count=100) as results_sb:
while True:
@ -69,7 +70,8 @@ class TaskResultHandlerService(service.Service):
while True:
try:
with self._create_mq_client() as mqClient:
mqClient.declare(conf.reports_exchange, conf.reports_queue)
mqClient.declare(conf.reports_exchange, conf.reports_queue,
enable_ha=True)
with mqClient.open(conf.reports_queue,
prefetch_count=100) as reports_sb:
while True:

2
muranoapi/db/services/environments.py
View File

@ -132,7 +132,7 @@ class EnvironmentServices(object):
}
with MqClient(**connection_params) as mqClient:
mqClient.declare('tasks', 'tasks')
mqClient.declare('tasks', 'tasks', enable_ha=True)
mqClient.send(message, 'tasks', 'tasks')
with unit.begin():

2
muranoapi/db/services/sessions.py
View File

@ -149,5 +149,5 @@ class SessionServices(object):
}
with MqClient(**connection_params) as mqClient:
mqClient.declare('tasks', 'tasks')
mqClient.declare('tasks', 'tasks', enable_ha=True)
mqClient.send(message, 'tasks', 'tasks')

3
requirements.txt
View File

@ -30,4 +30,5 @@ passlib
jsonschema>=1.3.0,!=1.4.0
python-keystoneclient>=0.4.1
oslo.config>=1.2.0
murano-common>=0.2.2
# Please, revert to murano-common>=x.x.x before release
http://tarballs.openstack.org/murano-common/murano-common-master.tar.gz#egg=murano-common-0.4