From 76301219aec0432004732f0706c822bc6a4c9d46 Mon Sep 17 00:00:00 2001 From: Roman Bazalevskiy Date: Mon, 2 Apr 2018 09:25:36 +0300 Subject: [PATCH] =?utf8?q?=D0=9A=D0=BE=D1=80=D1=80=D0=B5=D0=BA=D1=82=D0=BD?= =?utf8?q?=D0=BE=20=D0=BB=D0=BE=D0=B2=D0=B8=D1=82=D1=81=D1=8F=20=D0=B8?= =?utf8?q?=D1=81=D0=BA=D0=BB=D1=8E=D1=87=D0=B5=D0=BD=D0=B8=D0=B5=20=D0=BF?= =?utf8?q?=D1=80=D0=B8=20=D0=BF=D0=B5=D1=80=D0=B5=D0=B4=D0=B0=D1=87=D0=B5?= =?utf8?q?=20=D0=BD=D0=B5=D1=81=D1=83=D1=89=D0=B5=D1=81=D1=82=D0=B2=D1=83?= =?utf8?q?=D1=8E=D1=89=D0=B5=D0=B9=20=D0=BA=D0=BE=D0=BC=D0=B0=D0=BD=D0=B4?= =?utf8?q?=D1=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit --- nmd/nl_mqtt.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/nmd/nl_mqtt.py b/nmd/nl_mqtt.py index d0b26b3..5261d43 100644 --- 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 } + + await self.commands_to_send_queue.put(mtrf_command) + except Exception as e: logger.exception(e) continue - await self.commands_to_send_queue.put(mtrf_command) async def send_command_to_noolite(self): -- 2.34.1