Update main.py

MO-RISE · Dec 7, 2022 · 9da78f6 · 9da78f6
1 parent 42b0b9e
commit 9da78f6
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/main.py b/main.py
@@ -46,6 +46,7 @@
 if MQTT_TLS:
     mq.tls_set()
 mq.enable_logger(LOGGER)
+LOGGER.info("Connecting to MQTT broker...")
 mq.connect(MQTT_BROKER_HOST, MQTT_BROKER_PORT)
 
 
@@ -176,8 +177,5 @@ def rotate_points_azimuth(input_stream):
     pipe_heading = source_heading.latest()
     pipe_rotate = source.zip(pipe_heading).map(rotate_points_azimuth).map(to_brefv_raw).sink(to_mqtt)
 
-    LOGGER.info("Connecting to MQTT broker...")
-    mq.connect(MQTT_BROKER_HOST, MQTT_BROKER_PORT)
-
     LOGGER.info("Setting up MQTT listener...")
     subscribe_to_mqtt()