Корректно ловится исключение при передаче несуществующей команды

diff --git a/nmd/nl_mqtt.py b/nmd/nl_mqtt.py
index d0b26b3ba6ace0291b4639af9f7cf09fa18de9ba..5261d43bc6e8525131bf3c08d3c1226f579ed4a9 100644 (file)
--- a/nmd/nl_mqtt.py
+++ b/nmd/nl_mqtt.py
@@ -126,10 +126,12 @@ class MqttDriver(metaclass=Singleton):
                       mtrf_command = { "mode": 2, "ch": channel, "cmd": 25, "fmt": 6, "d0": d0, "d1": d1, "id0": int(id[0:2],16), "id1": int(id[2:4],16), "id2": int(id[4:6],16), "id3": int(id[6:8],16), "ctr": 8 }
                     else:
                       mtrf_command = { "mode": 0, "ch": channel, "cmd": 25, "fmt": 6, "d0": d0, "d1": d1 }
                       mtrf_command = { "mode": 2, "ch": channel, "cmd": 25, "fmt": 6, "d0": d0, "d1": d1, "id0": int(id[0:2],16), "id1": int(id[2:4],16), "id2": int(id[4:6],16), "id3": int(id[6:8],16), "ctr": 8 }
                     else:
                       mtrf_command = { "mode": 0, "ch": channel, "cmd": 25, "fmt": 6, "d0": d0, "d1": d1 }

+
+                  await self.commands_to_send_queue.put(mtrf_command)
+

                 except Exception as e:
                   logger.exception(e)
                   continue
                 except Exception as e:
                   logger.exception(e)
                   continue

-                await self.commands_to_send_queue.put(mtrf_command)

                  
 
     async def send_command_to_noolite(self):
                  
 
     async def send_command_to_noolite(self):