diff options
| -rw-r--r-- | nova/rpc/impl_kombu.py | 3 |
1 files changed, 0 insertions, 3 deletions
diff --git a/nova/rpc/impl_kombu.py b/nova/rpc/impl_kombu.py index 5f47737d0..82eb651de 100644 --- a/nova/rpc/impl_kombu.py +++ b/nova/rpc/impl_kombu.py @@ -449,7 +449,6 @@ class Connection(object): def publisher_send(self, cls, topic, msg, **kwargs): """Send to a publisher based on the publisher class""" while True: - publisher = None try: publisher = cls(self.channel, topic, **kwargs) publisher.send(msg) @@ -458,8 +457,6 @@ class Connection(object): LOG.exception(_('Failed to publish message %s' % str(e))) try: self.reconnect() - if publisher: - publisher.reconnect(self.channel) except self.connection.connection_errors, e: pass |