Catch BusException

diff --git a/controlpi_plugins/wsclient.py b/controlpi_plugins/wsclient.py
index c833c39ee7832da4a042216dd5873ad94261dd70..9dd41365dfdfb48b243fcdd726dd970fd0dca875 100644 (file)
--- a/controlpi_plugins/wsclient.py
+++ b/controlpi_plugins/wsclient.py
@@ -7,7 +7,7 @@ import struct
 from websockets.exceptions import ConnectionClosed, InvalidMessage
 from websockets.legacy.client import connect, WebSocketClientProtocol
 
-from controlpi import BasePlugin, Message, MessageTemplate
+from controlpi import BasePlugin, Message, MessageTemplate, BusException
 
 from typing import Optional, Dict, Any
 
@@ -205,4 +205,7 @@ class WSClient(BasePlugin):
         translated_message = translate_message(message,
                                                self.name, self._client)
         if translated_message is not None:
-            await self.bus.send(Message(self.name, translated_message))
+            try:
+                await self.bus.send(Message(self.name, translated_message))
+            except BusException as e:
+                print(f"WSClient to {self.conf['url']}: {e}")