From ca8bdf54757dbb7127c6fcf43ad7765a42ff5aff Mon Sep 17 00:00:00 2001 From: Benjamin Braatz Date: Fri, 1 Jul 2022 12:19:47 +0200 Subject: [PATCH] Catch BusException --- controlpi_plugins/wsclient.py | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/controlpi_plugins/wsclient.py b/controlpi_plugins/wsclient.py index c833c39..9dd4136 100644 --- 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}") -- 2.34.1