--- a/amqp/transport.py +++ b/amqp/transport.py @@ -111,6 +111,8 @@ class _AbstractTransport(object): try: self.sock.settimeout(None) self.sock.setsockopt(SOL_TCP, socket.TCP_NODELAY, 1) + socket.TCP_USER_TIMEOUT = 18 + self.sock.setsockopt(socket.SOL_TCP, socket.TCP_USER_TIMEOUT, 30) self.sock.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1) self._setup_transport()