I publish message using: client.publish(topic_pub, payload, retain=True)
I can see most recent message and also previous messages with `mosquito_sub`:
# mosquitto_sub -t 'proxies/#'
{"datetime": "2023-02-25 09:01:42", "erf_endpoint": "us-ca101.sugar.net", "erf_ipaddr": "107.150.28.85"}
{"datetime": "2023-02-25 08:37:31", "erf_endpoint": "us-ca101.sugar.net", "erf_ipaddr": "6.6.1.1"}
{"datetime": "2023-02-26 08:33:11", "erf_endpoint": "us-nj3.sugar.net", "erf_ipaddr": "100.2.3.4"}
However, when I use paho mqtt I'm only seeing the older messages, not the most recent.
def mqtt_on_connect(client, userdata, flags, rc):
client.subscribe(topic_sub)
def mqtt_on_message(client, userdata, msg):
messages.append(msg)
client.disconnect()
client = mqtt.Client()
client.on_connect = mqtt_on_connect
client.on_message = mqtt_on_message
client.connect(mqtt_broker)
client.loop_forever()
{"datetime": "2023-02-25 09:01:42", "erf_endpoint": "us-ca101.sugar.net", "erf_ipaddr": "107.150.28.85"}
{"datetime": "2023-02-25 08:37:31", "erf_endpoint": "us-ca101.sugar.net", "erf_ipaddr": "6.6.1.1"}
What am I doing wrong here?
Home
