openstack/oslo.messaging
Code Issues Proposed changes

Fix fanout exchange name pattern

Browse Source 
Change-Id: I0e3a85fe9bbd4a597b555302aa2c1c24045d2eec
This commit is contained in:
dukhlov 2015-10-24 17:13:06 -04:00
parent a415bdfb91
commit 9cae182b49
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
oslo_messaging/_drivers/impl_pika.py
View File

@ -812,7 +812,9 @@ class RpcServicePikaListener(PikaListener):
queue = '{}'.format(self._target.topic)
server_queue = '{}.{}'.format(queue, self._target.server)
fanout_exchange = '{}_fanout'.format(self._target.topic)
fanout_exchange = '{}_fanout_{}'.format(
self._pika_engine.default_rpc_exchange, self._target.topic
)
queue_expiration = (
self._pika_engine.conf.oslo_messaging_pika.rpc_queue_expiration
@ -997,7 +999,9 @@ class PikaDriver(object):
if target.fanout:
return msg.send(
exchange='{}_fanout'.format(target.topic),
exchange='{}_fanout_{}'.format(
self._pika_engine.default_rpc_exchange, target.topic
),
timeout=timeout, confirm=True, mandatory=False,
retrier=retrier
)