From 898142e6106a7f80c408c1d58fd8a3027dc12414 Mon Sep 17 00:00:00 2001 From: JungDev Date: Wed, 2 Jan 2019 16:18:35 +0100 Subject: [PATCH] Update apps.py --- django_telegrambot/apps.py | 22 +++++++++++----------- 1 file changed, 11 insertions(+), 11 deletions(-) diff --git a/django_telegrambot/apps.py b/django_telegrambot/apps.py index ccbbd7c..1fb5586 100644 --- a/django_telegrambot/apps.py +++ b/django_telegrambot/apps.py @@ -167,22 +167,22 @@ def ready(self): allowed_updates = b.get('ALLOWED_UPDATES', None) timeout = b.get('TIMEOUT', None) - proxy = b.get('PROXY', None) + proxy = b.get('PROXY', None) if self.mode == WEBHOOK_MODE: try: if b.get('MESSAGEQUEUE_ENABLED',False): q = mq.MessageQueue(all_burst_limit=b.get('MESSAGEQUEUE_ALL_BURST_LIMIT',29), - all_time_limit_ms=b.get('MESSAGEQUEUE_ALL_TIME_LIMIT_MS',1024)) - if proxy: - request = Request(proxy_url=proxy['proxy_url'], urllib3_proxy_kwargs=proxy['urllib3_proxy_kwargs'], con_pool_size=b.get('MESSAGEQUEUE_REQUEST_CON_POOL_SIZE',8)) - else: - request = Request(con_pool_size=b.get('MESSAGEQUEUE_REQUEST_CON_POOL_SIZE',8)) - bot = MQBot(token, request=request, mqueue=q) - else: - request = None - if proxy: - request = Request(proxy_url=proxy['proxy_url'], urllib3_proxy_kwargs=proxy['urllib3_proxy_kwargs']) + all_time_limit_ms=b.get('MESSAGEQUEUE_ALL_TIME_LIMIT_MS',1024)) + if proxy: + request = Request(proxy_url=proxy['proxy_url'], urllib3_proxy_kwargs=proxy['urllib3_proxy_kwargs'], con_pool_size=b.get('MESSAGEQUEUE_REQUEST_CON_POOL_SIZE',8)) + else: + request = Request(con_pool_size=b.get('MESSAGEQUEUE_REQUEST_CON_POOL_SIZE',8)) + bot = MQBot(token, request=request, mqueue=q) + else: + request = None + if proxy: + request = Request(proxy_url=proxy['proxy_url'], urllib3_proxy_kwargs=proxy['urllib3_proxy_kwargs']) bot = telegram.Bot(token=token, request=request) DjangoTelegramBot.dispatchers.append(Dispatcher(bot, None, workers=0))