diff options
| author | Jenkins <jenkins@review.openstack.org> | 2013-07-22 21:00:54 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2013-07-22 21:00:54 +0000 |
| commit | e1ccaf46205057e6a557fdee9f00ec9962d4e292 (patch) | |
| tree | 429a11683c571e278a2a3b572410022c0835b77f /openstack | |
| parent | cd78a6dbd48c346aabbc5554386d42ac5a4a5771 (diff) | |
| parent | 34a684200e2f34be2f7c0b86da48c0c46691fe46 (diff) | |
| download | oslo-e1ccaf46205057e6a557fdee9f00ec9962d4e292.tar.gz oslo-e1ccaf46205057e6a557fdee9f00ec9962d4e292.tar.xz oslo-e1ccaf46205057e6a557fdee9f00ec9962d4e292.zip | |
Merge "On reconnecting a FanoutConsumer, don't grow the topic name"
Diffstat (limited to 'openstack')
| -rw-r--r-- | openstack/common/rpc/impl_qpid.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/openstack/common/rpc/impl_qpid.py b/openstack/common/rpc/impl_qpid.py index 7fd835a..99c4619 100644 --- a/openstack/common/rpc/impl_qpid.py +++ b/openstack/common/rpc/impl_qpid.py @@ -238,7 +238,7 @@ class FanoutConsumer(ConsumerBase): {"exclusive": True}) def reconnect(self, session): - topic = self.get_node_name() + topic = self.get_node_name().rpartition('_fanout')[0] params = { 'session': session, 'topic': topic, |