code: def on_consume_ready(self, connection, channel, consumers, **kwargs):
          
          if not self._consumers_ready.ready():
              _log.debug('consumer started %s', self)
              self._consumers_ready.send(None)
docs: Kombu callback when consumers are ready to accept messages.
  
          Called after any (re)connection to the broker.