Open Stack

Hello,

I am checking current implementation to use rabbitmq mirrored queue, and am wondering why only DirectConsumer's queue is not mirrored.
What I am trying to say is, TopicConsumer's queue is declared with
{'x-ha-policy': 'all'} like below.

> class TopicConsumer(ConsumerBase):
> ... snip
>         # Default options
>         options = {'durable': conf.rabbit_durable_queues,
>  mirrored  -->     'queue_arguments': _get_queue_arguments(conf),
>                    'auto_delete': False,
>                   'exclusive': False}

We can see same declaration at FanoutConsumer, but not DirectConsumer.
As you know, rpc.call() send request through TopicConsumer, and return values  thorough DirectConsumer. So if TopicConsumer is mirrored, DirectConsumer also should be mirrored, I think.

I post this oslo core devs recommend me to ask here. Patch is on the review.
<https://review.openstack.org/#/c/20240/>

I hope someone who is familiar with rabbitmq replys... 

----------------------------------------------------------------
Kei Masumoto <masumotok at nttdata.co.jp>
Senior expert, System Platform Business Unit, NTTData Corp.