From 34a684200e2f34be2f7c0b86da48c0c46691fe46 Mon Sep 17 00:00:00 2001 From: Michael Wilson Date: Mon, 15 Jul 2013 12:57:38 -0600 Subject: 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 --- openstack/common/rpc/impl_qpid.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'openstack') 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, -- cgit