From: Benjamin Braatz <benjamin.braatz@graph-it.com>
Date: Wed, 8 Sep 2021 12:44:44 +0000 (+0200)
Subject: Only send message if bus client callback still there.
X-Git-Tag: v0.3.0~17
X-Git-Url: http://git.graph-it.com/?a=commitdiff_plain;h=509acdf47a2877be602924b05a62d170a15e4607;p=graphit%2Fcontrolpi.git

Only send message if bus client callback still there.
---

diff --git a/controlpi/messagebus.py b/controlpi/messagebus.py
index 4ff3453..b320245 100644
--- a/controlpi/messagebus.py
+++ b/controlpi/messagebus.py
@@ -1177,7 +1177,8 @@ class MessageBus:
                         with open(sys.argv[1], 'w') as conf_file:
                             json.dump(message['conf'], conf_file)
             for client in self._recv_reg.get(message):
-                await self._callbacks[client](message)
+                if client in self._callbacks:
+                    await self._callbacks[client](message)
             self._queue.task_done()
 
     async def send(self, message: Message) -> None: