--- amqp/transport.py +++ amqp/transport.py @@ -98,6 +98,12 @@ self.sock.settimeout(None) self.sock.setsockopt(SOL_TCP, socket.TCP_NODELAY, 1) self.sock.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1) + # If connection is idle for more than KEEPIDLE seconds + # Start sending a probe every KEEPINTVL seconds + # for KEEPCNT times. If none respond, about the connection + self.sock.setsockopt(socket.SOL_TCP, socket.TCP_KEEPIDLE, 60) + self.sock.setsockopt(socket.SOL_TCP, socket.TCP_KEEPINTVL, 10) + self.sock.setsockopt(socket.SOL_TCP, socket.TCP_KEEPCNT, 9) self._setup_transport()