diff options
| author | Michael Wilson <geekinutah@gmail.com> | 2013-07-15 12:57:38 -0600 |
|---|---|---|
| committer | Michael Wilson <geekinutah@gmail.com> | 2013-07-20 15:27:41 -0600 |
| commit | 34a684200e2f34be2f7c0b86da48c0c46691fe46 (patch) | |
| tree | ed2cfcd92ae93e07e0a4b06677c8ef0cd064233b /openstack | |
| parent | 6dd15766c82079db345a45cc20a9410c968cd599 (diff) | |
| download | oslo-34a684200e2f34be2f7c0b86da48c0c46691fe46.tar.gz oslo-34a684200e2f34be2f7c0b86da48c0c46691fe46.tar.xz oslo-34a684200e2f34be2f7c0b86da48c0c46691fe46.zip | |
On reconnecting a FanoutConsumer, don't grow the topic name
Commit 719eba4cae7f2bc11753b17c65c7597b8d6ed72d in oslo-incubator
introduced a small bug on reconnect. Because of the way the topic
was extracted, an extra '_fanout' gets tacked onto the topic name
with each reconnect. A one line fix in code (rpartition) and test
case are needed.
Change-Id: I7b3ca48502c9d5a99802c24dfcec0a1a8292fa07
Fixes: bug #1201552
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, |