php-amqplib / php-amqplib

     * @throws \PhpAmqpLib\Exception\AMQPTimeoutException if the specified operation timeout was exceeded

     * @return mixed

     */

    public function basic_qos($prefetch_size, $prefetch_count, $a_global)

    {

        list($class_id, $method_id, $args) = $this->protocolWriter->basicQos(

            $prefetch_size,

            $prefetch_count,

            $a_global

        );

        $this->send_method_frame(array($class_id, $method_id), $args);

        return $this->wait(array(

            $this->waitHelper->get_wait('basic.qos_ok')

        ), false, $this->channel_rpc_timeout);

    }

    /**

     * Confirms QoS request

     * @throws \PhpAmqpLib\Exception\AMQPTimeoutException if the specified operation timeout was exceeded

     * @return mixed

     */

    public function basic_recover($requeue = false)

    {

        list($class_id, $method_id, $args) = $this->protocolWriter->basicRecover($requeue);

        $this->send_method_frame(array($class_id, $method_id), $args);

        return $this->wait(array(

            $this->waitHelper->get_wait('basic.recover_ok')

        ), false, $this->channel_rpc_timeout);

    }

    /**

     * Confirm the requested recover