def on_consume_ready(self, connection, channel, consumers, **kwargs):
        """ Kombu callback when consumers are ready to accept messages.

        Called after any (re)connection to the broker.
        """
        if not self._consumers_ready.ready():
            _log.debug('consumer started %s', self)
            self._consumers_ready.send(None)

        for provider in self._providers:
            try:
                callback = provider.on_consume_ready
            except __HOLE__:
                pass
            else:
                callback()
dataset/ETHPy150Open onefinestay/nameko/nameko/messaging.py/QueueConsumer.on_consume_ready