code: def Consumer(self, channel, **kwargs):
          
          kwargs.setdefault('no_ack', self.no_ack)
          return Consumer(channel, self.get_queues(),
                          callbacks=[self.on_message], **kwargs)
docs: Returns a :class:`kombu.Consumer` instance for this Actor