MQTTClient.py 文件源码

def __init__(self, clientID, cleanSession, protocol):
        self.client_id = clientID
        self._cleanSession = cleanSession
        self._protocol = protocol
        self._userdata = None
        self._user = ""
        self._password = ""
        self._keepAliveInterval = 60
        self._will = False
        self._will_topic = ""
        self._will_message= None
        self._will_qos = 0
        self._will_retain = False
        self._connectdisconnectTimeout = 30
        self._mqttOperationTimeout = 5
        self._topic_callback_queue=[]
        self._callback_mutex=_thread.allocate_lock()
        self._pid = 0
        self._subscribeSent = False
        self._unsubscribeSent = False
        self._baseReconnectTimeSecond=1
        self._maximumReconnectTimeSecond=32
        self._minimumConnectTimeSecond=20
        self._msgHandler=msgHandler.MsgHandler(self._recv_callback)