From 43c9ed1edc8c6e0812869cc9fc2a009371fefcc8 Mon Sep 17 00:00:00 2001 From: Jan Speller Date: Tue, 14 Jul 2020 08:39:41 +0200 Subject: [PATCH] add new parameter to disable queue --- plugin/telegram.py | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/plugin/telegram.py b/plugin/telegram.py index a68f536..9bc5ef1 100644 --- a/plugin/telegram.py +++ b/plugin/telegram.py @@ -59,9 +59,14 @@ class BoswatchPlugin(PluginBase): def onLoad(self): """!Called by import of the plugin""" - q = mq.MessageQueue() - request = Request(con_pool_size=8) - self.bot = MQBot(token=self.config.get("botToken", default=""), request=request, mqueue=q) + if self.config.get("queue", default=True): + q = mq.MessageQueue() + request = Request(con_pool_size=8) + self.bot = MQBot(token=self.config.get("botToken", default=""), request=request, mqueue=q) + print('queue') + else: + self.bot = telegram.Bot(token=self.config.get("botToken")) + print('normal') def fms(self, bwPacket): """!Called on FMS alarm