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)

        for provider in self._providers:
            try:
                callback = provider.on_consume_ready
            except AttributeError:
                pass
            else:
                callback()
The 'add' admin view for this model.
dataset/ETHPy150Open onefinestay/nameko/nameko/messaging.py/QueueConsumer.on_consume_ready--crossover with--dataset/ETHPy150Open cloudera/hue/desktop/core/ext-py/Django-1.6.10/django/contrib/admin/options.py/ModelAdmin.add_view