diff options
| -rw-r--r-- | oslo_messaging/_drivers/impl_rabbit.py | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/oslo_messaging/_drivers/impl_rabbit.py b/oslo_messaging/_drivers/impl_rabbit.py index 639ca8e..a36afc2 100644 --- a/oslo_messaging/_drivers/impl_rabbit.py +++ b/oslo_messaging/_drivers/impl_rabbit.py @@ -19,6 +19,7 @@ import os import random import socket import ssl +import sys import threading import time import uuid @@ -846,8 +847,10 @@ class Connection(object): LOG.debug('Failed to get socket attribute: %s' % str(e)) else: sock.settimeout(timeout) - sock.setsockopt(socket.IPPROTO_TCP, TCP_USER_TIMEOUT, - timeout * 1000 if timeout is not None else 0) + if sys.platform != 'win32': + sock.setsockopt(socket.IPPROTO_TCP, + TCP_USER_TIMEOUT, + timeout * 1000 if timeout is not None else 0) @contextlib.contextmanager def _transport_socket_timeout(self, timeout): |