diff options
| author | Kei Masumoto <masumotok@nttdata.co.jp> | 2013-02-13 23:20:26 +0900 |
|---|---|---|
| committer | Kei Masumoto <masumotok@nttdata.co.jp> | 2013-02-13 23:23:26 +0900 |
| commit | 568e533c3accb15d01bf6a8ebbf600a68b920916 (patch) | |
| tree | 8ec8a22b3f0e4077ed9ee3346e39b41777e180bd /openstack/common/rpc | |
| parent | eaab5fae2502198e9fa57d0d90a7204a2bd83b16 (diff) | |
Fix "DirectConsumer needs mirrored queue support"
Currently TopicCosumer and FanoutConsumer can be used
Mirrored Queue support, but not DirectConsumer.
This patch fix this issue.
Fix bug 1124162
Change-Id: I68ae23467ae810ce0ec917a4cb34a488283f401c
Diffstat (limited to 'openstack/common/rpc')
| -rw-r--r-- | openstack/common/rpc/impl_kombu.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/openstack/common/rpc/impl_kombu.py b/openstack/common/rpc/impl_kombu.py index 4f3cc7a..c827a68 100644 --- a/openstack/common/rpc/impl_kombu.py +++ b/openstack/common/rpc/impl_kombu.py @@ -197,6 +197,7 @@ class DirectConsumer(ConsumerBase): """ # Default options options = {'durable': False, + 'queue_arguments': _get_queue_arguments(conf), 'auto_delete': True, 'exclusive': False} options.update(kwargs) |