Use get_errno

2013-03-11 15:26:42 +09:00 · 2013-03-11 15:26:42 +09:00 · f6ff4df21b
parent 009deb8898
commit f6ff4df21b
1 changed files with 1 additions and 1 deletions
--- 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