diff options
Diffstat (limited to 'amqp/transport.py')
| -rw-r--r-- | amqp/transport.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/amqp/transport.py b/amqp/transport.py index 2761f09..c915977 100644 --- a/amqp/transport.py +++ b/amqp/transport.py @@ -401,6 +401,8 @@ class SSLTransport(_AbstractTransport): def _setup_transport(self): """Wrap the socket in an SSL object.""" self.sock = self._wrap_socket(self.sock, **self.sslopts) + # Explicitly set a timeout here to stop any hangs on handshake. + self.sock.settimeout(self.connect_timeout) self.sock.do_handshake() self._quick_recv = self.sock.read |