diff --git a/kombu/connection.py b/kombu/connection.py index f921de8d..496494e3 100644 --- a/kombu/connection.py +++ b/kombu/connection.py @@ -290,7 +290,7 @@ class Connection(object): self.more_to_read = False return False except socket.error, exc: - if exc.errno in (errno.EAGAIN, errno.EINTR): + if get_errno(exc) in (errno.EAGAIN, errno.EINTR): self.more_to_read = False return False raise