diff --git a/kombu/transport/qpid.py b/kombu/transport/qpid.py index 94ba336a..756b0ef0 100644 --- a/kombu/transport/qpid.py +++ b/kombu/transport/qpid.py @@ -1731,7 +1731,7 @@ class Transport(base.Transport): def __del__(self): """Ensure file descriptors opened in __init__() are closed.""" - if self.use_async_interface: + if getattr(self, 'use_async_interface', False): for fd in (self.r, self._w): try: os.close(fd)