def thread(self):
        """
        Start a thread for this consumer.
        """
        log.info('@{}.thread starting'.format(self.__class__.__name__))
        thread = threading.Thread(target=thread_wrapper(self.consume), args=())
        thread.daemon = True
        thread.start()
def thread ( self ) : log . info ( '@{}.thread starting' . format ( self . __class__ . __name__ ) ) thread = threading . Thread ( target = thread_wrapper ( self . consume ) , args = ( ) ) thread . daemon = True thread . start ( )
Start a thread for this consumer.