def __init__(self, process_name):
        """:param process_name: id of the process, the worker will be performing """
        super(AbstractMqWorker, self).__init__(process_name)
        self.mq_timeout_seconds = 0
        self._init_mq_timeout_seconds()

        self.consumer = None
        self._init_mq_consumer()

        self.main_thread = None
        self.performance_tracker = None
        self._init_performance_tracker(self.logger)

        msg_suffix = 'in Production Mode'
        if settings.settings['under_test']:
            msg_suffix = 'in Testing Mode'
        self.logger.info('Started {0} {1}'.format(self.process_name, msg_suffix))
def __init__ ( self , process_name ) : super ( AbstractMqWorker , self ) . __init__ ( process_name ) self . mq_timeout_seconds = 0 self . _init_mq_timeout_seconds ( ) self . consumer = None self . _init_mq_consumer ( ) self . main_thread = None self . performance_tracker = None self . _init_performance_tracker ( self . logger ) msg_suffix = 'in Production Mode' if settings . settings [ 'under_test' ] : msg_suffix = 'in Testing Mode' self . logger . info ( 'Started {0} {1}' . format ( self . process_name , msg_suffix ) )
:param process_name: id of the process, the worker will be performing