videlalvaro / php-amqplib

    /**

     * @return array

     */

    public function basicQos($prefetch_size = 0, $prefetch_count = 0, $global = false)

    {

        $args = new AMQPWriter();

        $args->write_long($prefetch_size);

        $args->write_short($prefetch_count);

        $args->write_bits(array($global));

        return array(60, 10, $args);

    }

    /**

     * @return array

     */

    public function fileQos($prefetch_size = 0, $prefetch_count = 0, $global = false)

    {

        $args = new AMQPWriter();

        $args->write_long($prefetch_size);

        $args->write_short($prefetch_count);

        $args->write_bits(array($global));

        return array(70, 10, $args);

    }

    /**

     * @return array

     */

    public function streamQos($prefetch_size = 0, $prefetch_count = 0, $consume_rate = 0, $global = false)

    {

        $args = new AMQPWriter();

        $args->write_long($prefetch_size);

        $args->write_short($prefetch_count);

        $args->write_long($consume_rate);

        $args->write_bits(array($global));

        return array(80, 10, $args);

    }

    /**

     * @return array

     */

    public function basicQos($prefetch_size = 0, $prefetch_count = 0, $global = false)

    {

        $args = new AMQPWriter();

        $args->write_long($prefetch_size);

        $args->write_short($prefetch_count);

        $args->write_bits(array($global));

        return array(60, 10, $args);

    }