From 83eea8ff407aa3c3c0cff113e0233bdba53470f7 Mon Sep 17 00:00:00 2001 From: Roger Light Date: Mon, 26 Aug 2013 21:13:46 +0100 Subject: [PATCH] Fix support for Python 2.6, 3.0, 3.1. --- src/paho/mqtt/client.py | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/src/paho/mqtt/client.py b/src/paho/mqtt/client.py index 9001bb5..1ba6f9b 100755 --- a/src/paho/mqtt/client.py +++ b/src/paho/mqtt/client.py @@ -559,6 +559,9 @@ class Client: raise ValueError('Invalid port number.') if keepalive < 0: raise ValueError('Keepalive must be >=0.') + if bind_address != "" and bind_address != None: + if (sys.version_info[0] == 2 and sys.version_info[1] < 7) or (sys.version_info[0] == 3 and sys.version_info[1] < 2): + raise ValueError('bind_address requires Python 2.7 or 3.2.') self._host = host self._port = port @@ -607,7 +610,10 @@ class Client: self._messages_reconnect_reset() try: - self._sock = socket.create_connection((self._host, self._port), source_address=(self._bind_address, 0)) + if (sys.version_info[0] == 2 and sys.version_info[1] < 7) or (sys.version_info[0] == 3 and sys.version_info[1] < 2): + self._sock = socket.create_connection((self._host, self._port), source_address=(self._bind_address, 0)) + else: + self._sock = socket.create_connection((self._host, self._port)) except socket.error as err: (msg) = err if msg.errno != errno.EINPROGRESS: -- 2.39.5