Sorry, realized I created the patch the wrong way. :facepalm:
This is how it *should* be:
--- impl_kombu.py.orig 2013-08-22 21:52:37.727386558 +0000 +++ impl_kombu.py.new 2013-08-22 21:52:54.711337602 +0000 @@ -488,6 +488,7 @@ self.connection = None self.connection = kombu.connection.BrokerConnection(**params) self.connection_errors = self.connection.connection_errors + self.channel_errors = self.connection.channel_errors if self.memory_transport: # Kludge to speed up tests. self.connection.transport.polling_interval = 0.0 @@ -561,7 +562,7 @@ while True: try: return method(*args, **kwargs) - except (self.connection_errors, socket.timeout, IOError), e: + except (self.channel_errors, socket.timeout, IOError), e: if error_callback: error_callback(e) except Exception, e:
Sorry, realized I created the patch the wrong way. :facepalm:
This is how it *should* be:
--- impl_kombu.py.orig 2013-08-22 21:52:37.727386558 +0000
self. connection = None
self. connection = kombu.connectio n.BrokerConnect ion(**params)
self. connection_ errors = self.connection .connection_ errors .channel_ errors transport:
self. connection. transport. polling_ interval = 0.0
return method(*args, **kwargs) n_errors, socket.timeout, IOError), e: errors, socket.timeout, IOError), e:
error_callback( e)
+++ impl_kombu.py.new 2013-08-22 21:52:54.711337602 +0000
@@ -488,6 +488,7 @@
+ self.channel_errors = self.connection
if self.memory_
# Kludge to speed up tests.
@@ -561,7 +562,7 @@
while True:
try:
- except (self.connectio
+ except (self.channel_
if error_callback:
except Exception, e: