def connect(self, host, port, username, password):
    info('mqtt', 'connect')
    self.client.username_pw_set(username, password)
    self.client.connect(host, port=port, keepalive=60)
    self.client.loop_start()
def connect(self, host, port, username, password):
    info('mqtt', 'connect')
    self.client.username_pw_set(username, password)
    self.client.connect(host, port=port, keepalive=60)
    self.client.loop_start()