Map.py 文件源码

def Publish(self, target, channel, message):
                client = mqtt.Client()
                #client.on_publish = self.on_publish
        client.max_inflight_messages_set(200000)
                client.connect(target, 1883)
        client.loop_start()
                msg_info = client.publish(channel, message, qos=1)
        if msg_info.is_published() == False:
            msg_info.wait_for_publish()
        client.disconnect()
        #time.sleep(0.01)
        print "MAP MQTT IS PUBLISH : "+str(msg_info.is_published())
        print "MAP MQTT IP : "+target
        print "MAP MQTT MESSAGE : "+message
        print ""