@@ -599,7 +599,7 @@ def connect_mqtt():
|
|||||||
password=MQTT_PASSWORD,
|
password=MQTT_PASSWORD,
|
||||||
keepalive=60,
|
keepalive=60,
|
||||||
)
|
)
|
||||||
client.set_last_will(gauge_topics[0]["status"], b"offline", retain=True, qos=0)
|
client.set_last_will(T_STATUS, b"offline", retain=True, qos=0)
|
||||||
client.set_callback(on_message)
|
client.set_callback(on_message)
|
||||||
client.connect()
|
client.connect()
|
||||||
client_ref = client
|
client_ref = client
|
||||||
@@ -653,9 +653,7 @@ def check_mqtt():
|
|||||||
password=MQTT_PASSWORD,
|
password=MQTT_PASSWORD,
|
||||||
keepalive=60,
|
keepalive=60,
|
||||||
)
|
)
|
||||||
client_ref.set_last_will(
|
client_ref.set_last_will(T_STATUS, b"offline", retain=True, qos=0)
|
||||||
gauge_topics[0]["status"], b"offline", retain=True, qos=0
|
|
||||||
)
|
|
||||||
client_ref.set_callback(on_message)
|
client_ref.set_callback(on_message)
|
||||||
client_ref.connect()
|
client_ref.connect()
|
||||||
client_ref.subscribe(T_SET)
|
client_ref.subscribe(T_SET)
|
||||||
|
|||||||
Reference in New Issue
Block a user