<SYSTEM_TASK:>
Solve the following problem using Python, implementing the functions described below, one line at a time
<END_TASK>
<USER_TASK:>
Description:
 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)