Browse Source

subscribe in the connect callback (fixes #814)

Blake Blackshear 4 years ago
parent
commit
1a7853a47e
1 changed files with 1 additions and 0 deletions
  1. 1 0
      frigate/mqtt.py

+ 1 - 0
frigate/mqtt.py

@@ -91,6 +91,7 @@ def create_mqtt_client(config: FrigateConfig, camera_metrics):
                 logger.error("Unable to connect to MQTT: Connection refused. Error code: " + str(rc))
                 logger.error("Unable to connect to MQTT: Connection refused. Error code: " + str(rc))
             
             
         logger.info("MQTT connected")
         logger.info("MQTT connected")
+        client.subscribe(f"{mqtt_config.topic_prefix}/#")
         client.publish(mqtt_config.topic_prefix+'/available', 'online', retain=True)   
         client.publish(mqtt_config.topic_prefix+'/available', 'online', retain=True)   
 
 
     client = mqtt.Client(client_id=mqtt_config.client_id)    
     client = mqtt.Client(client_id=mqtt_config.client_id)