'Callback called when the Consumer blueprint is fully started.'

def on_consumer_ready(self, consumer):

    self._on_started.set()
    test_worker_started.send(sender=self.app, worker=self, consumer=consumer)
