code: def setup_queue(self):
          
          logger.debug("Declaring queue %s" % self._queue)
          self._channel.queue_declare(self.on_queue_declareok, self._queue, durable=True)
docs: Declare the queue
  
          When completed, the on_queue_declareok method will be invoked by pika.