diff options
Diffstat (limited to 'librabbitmq/__init__.py')
| -rw-r--r-- | librabbitmq/__init__.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/librabbitmq/__init__.py b/librabbitmq/__init__.py index a1d7e3b..ee7a06c 100644 --- a/librabbitmq/__init__.py +++ b/librabbitmq/__init__.py @@ -191,7 +191,7 @@ class Connection(_librabbitmq.Connection): def __init__(self, host='localhost', userid='guest', password='guest', virtual_host='/', port=5672, channel_max=0xffff, frame_max=131072, heartbeat=0, lazy=False, - client_properties=None, **kwargs): + client_properties=None, connect_timeout=None, **kwargs): if ':' in host: host, port = host.split(':') super(Connection, self).__init__( @@ -199,6 +199,7 @@ class Connection(_librabbitmq.Connection): virtual_host=virtual_host, channel_max=channel_max, frame_max=frame_max, heartbeat=heartbeat, client_properties=client_properties, + connect_timeout=0 if connect_timeout is None else int(connect_timeout), ) self.channels = {} self._used_channel_ids = array('H') |