mqtt_gobject_bridge.py 文件源码

def _init_mqtt(self):
        try:
            logging.info('[Init] Connecting to local broker')
            if self._mqtt_user is not None and self._mqtt_passwd is not None:
                self._client.username_pw_set(self._mqtt_user, self._mqtt_passwd)
            if self._ca_cert is None:
                self._client.connect(self._mqtt_server, 1883, 60)
            else:
                self._client.tls_set(self._ca_cert, cert_reqs=ssl.CERT_REQUIRED)
                self._client.connect(self._mqtt_server, 8883, 60)
            self._init_socket_handlers()
            return False
        except socket.error, e:
            if e.errno == errno.ECONNREFUSED:
                return True
            raise