set WebSockets path (#70)

wmo-im · Aug 26, 2024 · 8b6b9c3 · 8b6b9c3
1 parent 13d197d
commit 8b6b9c3
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/pywis_pubsub/mqtt.py b/pywis_pubsub/mqtt.py
@@ -70,6 +70,10 @@ def __init__(self, broker: str, options: dict = {}) -> None:
 
         self.conn.enable_logger(logger=LOGGER)
 
+        if self.broker_url.scheme in ['ws', 'wss']:
+            LOGGER.debug('Setting Websockets path: {self.broker_url.path}')
+            self.conn.ws_set_options(self.broker_url.path)
+
         if None not in [self.broker_url.username, self.broker_url.password]:
             LOGGER.debug('Setting credentials')
             self.conn.username_pw_set(