def handle(self, request, buffer_size):
        """
        Handle a message
        :param request: the request socket.
        :param buffer_size: the buffer size.
        :return: True if success, False otherwise
        """
        logger = self.logger
        msg = self.__receive(request, buffer_size)
        if msg is None:
            return False

        result = self.handler_function(msg)

        if self.component_type == StreamComponent.PROCESSOR:
            return self.__send(request, result)
        return True
def handle ( self , request , buffer_size ) : logger = self . logger msg = self . __receive ( request , buffer_size ) if msg is None : return False result = self . handler_function ( msg ) if self . component_type == StreamComponent . PROCESSOR : return self . __send ( request , result ) return True
Handle a message
        :param request: the request socket.
        :param buffer_size: the buffer size.
        :return: True if success, False otherwise