We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 8d2c1e2 commit c774ba3Copy full SHA for c774ba3
src/mqtt_gateway.py
@@ -75,6 +75,9 @@ def __select_publisher(self) -> Publisher:
75
return ConsolePublisher(self.configuration)
76
77
async def run(self) -> None:
78
+ LOG.info("Connecting to MQTT Broker")
79
+ await self.publisher.connect()
80
+
81
message_request_interval = self.configuration.messages_request_interval
82
await self.__do_initial_login(message_request_interval)
83
@@ -96,8 +99,6 @@ async def run(self) -> None:
96
99
name="Check for new messages",
97
100
max_instances=1,
98
101
)
- LOG.info("Connecting to MQTT Broker")
- await self.publisher.connect()
102
103
LOG.info("Starting scheduler")
104
self.__scheduler.start()
0 commit comments