(self, handler: Callable)
Set the handler function and start the invoker

        Use `stop()` to shutdown the invoker.
Set the handler function and start the invoker
Set the handler function and start the invoker
def start(self, handler: Callable):
        """Set the handler function and start the invoker

        Use `stop()` to shutdown the invoker.
        """
        logger.debug(
            f"Starting consumer for handler {handler.__qualname__}(). This should report ready"
            " shortly..."
        )
        self._consumer_task = asyncio.ensure_future(
            queue_exception_checker(self._consumer_loop(self.queue, handler), self.error_queue)
        )
        self._running_commands = set()
def start ( self , handler : Callable ) : logger . debug ( f"Starting consumer for handler {handler.__qualname__}(). This should report ready" " shortly..." ) self . _consumer_task = asyncio . ensure_future ( queue_exception_checker ( self . _consumer_loop ( self . queue , handler ) , self . error_queue ) ) self . _running_commands = set ( )