Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import telegram.bot
- from telegram.ext import messagequeue as mq
- class MQBot(telegram.bot.Bot):
- def __init__(self, *args, is_queued_def=True, mqueue=None, **kwargs):
- super(MQBot, self).__init__(*args, **kwargs)
- self._is_messages_queued_default = is_queued_def
- self._msg_queue = mqueue or mq.MessageQueue()
- def __del__(self):
- try:
- self._msg_queue.stop()
- except:
- pass
- super(MQBot, self).__del__()
- @mq.queuedmessage
- def send_message(self, *args, **kwargs):
- super(MQBot, self).send_message(*args, **kwargs)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement