Logger.py 文件源码

def main(self):
        """
        The main of the logger.
        """
        config = Config.get()

        # Startup logger.
        self.__startup()

        # Register our socket for asynchronous incoming messages.
        self.__message_controller.register_end_point('pull', zmq.PULL, config.get_logger_pull_end_point())

        # Register supported message types
        self.__message_controller.register_message_type(HaltMessage.MESSAGE_TYPE)
        self.__message_controller.register_message_type(LogFileMessage.MESSAGE_TYPE)

        # Register message received event handlers.
        self.__message_controller.register_listener(HaltMessage.MESSAGE_TYPE, HaltMessageEventHandler.handle)
        self.__message_controller.register_listener(LogFileMessage.MESSAGE_TYPE, LogFileMessageEventHandler.handle)

        # Register other event handlers.
        self.__event_controller.event_queue_empty.register_listener(self.__message_controller.receive_message)

        # Run the event loop.
        self.__event_controller.loop()

        # Shutdown logger.
        self.__shutdown()

    # ------------------------------------------------------------------------------------------------------------------