code: def _on_qosok(self, qosok_frame):
          
          for name, args in self._exchanges.items():
              self._channel.exchange_declare(
                  exchange=name,
                  exchange_type=args["type"],
                  durable=args["durable"],
                  auto_delete=args["auto_delete"],
                  arguments=args["arguments"],
                  passive=config.conf["passive_declares"],
                  callback=self._on_exchange_declareok,
              )
          for name, args in self._queues.items():
              self._channel.queue_declare(
                  queue=name,
                  durable=args["durable"],
                  auto_delete=args["auto_delete"],
                  exclusive=args["exclusive"],
                  arguments=args["arguments"],
                  passive=config.conf["passive_declares"],
                  callback=self._on_queue_declareok,
              )
docs: Callback invoked when the server acknowledges the QoS settings.
  
          Asserts or creates the exchanges and queues exist.
  
          Args:
              qosok_frame (pika.spec.Basic.Qos): The frame send from the server.