code: def get_consumers(self, consumer_cls, channel):
          
          _log.debug('setting up consumers %s', self)
  
          for provider in self._providers:
              callbacks = [partial(self.handle_message, provider)]
  
              consumer = consumer_cls(
                  queues=[provider.queue],
                  callbacks=callbacks,
                  accept=self.accept
              )
              consumer.qos(prefetch_count=self.prefetch_count)
  
              self._consumers[provider] = consumer
  
          return self._consumers.values()
docs: Kombu callback to set up consumers.
  
          Called after any (re)connection to the broker.