mirror of
https://github.com/Pardus-LiderAhenk/ahenk
synced 2024-11-15 13:42:18 +03:00
33 lines
1.2 KiB
Python
33 lines
1.2 KiB
Python
#!/usr/bin/python3
|
|
# -*- coding: utf-8 -*-
|
|
# Author: İsmail BAŞARAN <ismail.basaran@tubitak.gov.tr> <basaran.ismaill@gmail.com>
|
|
|
|
import threading
|
|
|
|
from base.Scope import Scope
|
|
|
|
|
|
class MessageResponseQueue(threading.Thread):
|
|
"""
|
|
This class handles responses and sends it to lider server.
|
|
"""
|
|
|
|
def __init__(self, outQueue):
|
|
super(MessageResponseQueue, self).__init__()
|
|
scope = Scope.getInstance()
|
|
self.logger = scope.getLogger()
|
|
self.messageManager = scope.getMessenger()
|
|
self.outQueue = outQueue
|
|
|
|
def run(self):
|
|
while True:
|
|
try:
|
|
# This item will send response to lider.
|
|
# item must be response message. Response message may be generic message type
|
|
responseMessage = self.outQueue.get(block=True)
|
|
self.logger.debug('[MessageResponseQueue] Sending response message to lider. Response Message ' + str(responseMessage))
|
|
# Call message manager for response
|
|
self.messageManager.send_direct_message(responseMessage)
|
|
# self.outQueue.task_done()
|
|
except Exception as e:
|
|
self.logger.error
|