code: def _on_queue_declareok(self, frame):
          
          _log.info("Successfully declared the %s queue", frame.method.queue)
          for binding in self._bindings:
              if binding["queue"] == frame.method.queue:
                  for key in binding["routing_keys"]:
                      _log.info(
                          "Asserting %s is bound to %s with the %s key",
                          binding["queue"],
                          binding["exchange"],
                          key,
                      )
                      self._channel.queue_bind(
                          callback=None,
                          queue=binding["queue"],
                          exchange=binding["exchange"],
                          routing_key=key,
                      )
                  bc_args = dict(queue=frame.method.queue)
                  if _pika_version < pkg_resources.parse_version("1.0.0b1"):
                      bc_args["consumer_callback"] = self._on_message
                  else:
                      bc_args["on_message_callback"] = self._on_message
                  tag = self._channel.basic_consume(**bc_args)
                  self._consumers[tag] = binding["queue"]
docs: Callback invoked when a queue is successfully declared.
  
          Args:
              frame (pika.frame.Method): The message sent from the server.