From 2cf777e0205c0493ba92079d28e56ea1fbe77d59 Mon Sep 17 00:00:00 2001 From: tony19990828 <58881058+tony19990828@users.noreply.github.com> Date: Thu, 17 Feb 2022 21:02:43 +0800 Subject: [PATCH] Update local_mqtt_sub_ros.py --- localRosData/local_mqtt_sub_ros.py | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/localRosData/local_mqtt_sub_ros.py b/localRosData/local_mqtt_sub_ros.py index 20e5564..2ca8678 100644 --- a/localRosData/local_mqtt_sub_ros.py +++ b/localRosData/local_mqtt_sub_ros.py @@ -18,7 +18,7 @@ def ros_pub(dataJson): # MQTT -def initialise_clients(cname): +def initialise_clients(clientname): # callback assignment initialise_client = mqtt.Client(clientname, False) initialise_client.topic_ack = [] @@ -26,7 +26,7 @@ def initialise_clients(cname): def on_connect(client, userdata, flags, rc): print("Connected with result code " + str(rc)) - client.subscribe(topic) + client.subscribe(mqtt_config["topic"]) def on_message(client, userdata, msg): @@ -35,10 +35,9 @@ def on_message(client, userdata, msg): if __name__ == '__main__': # Mqtt - mqtt_config = {"host": "192.168.50.180", "port": 1883, "topic": "data/pub"}" + mqtt_config = {"host": "127.0.0.1", "port": 1883, "topic": "data/pub"} client = initialise_clients("client1") - client.on_publish = on_publish - client.on_connect = on_connec + client.on_connect = on_connect client.connect(mqtt_config["host"], mqtt_config["port"], 60) client.loop_start()