videlalvaro / php-amqplib

    /**

     * @return array

     */

    public function exchangeDeclare($ticket = 1, $exchange, $type = 'direct', $passive = false, $durable = false, $auto_delete = false, $internal = false, $nowait = false, $arguments = array())

    {

        $args = new AMQPWriter();

        $args->write_short($ticket);

        $args->write_shortstr($exchange);

        $args->write_shortstr($type);

        $args->write_bits(array($passive, $durable, $auto_delete, $internal, $nowait));

        $args->write_table(empty($arguments) ? array() : $arguments);

        return array(40, 10, $args);

    }

    /**

     * @return array

     */

    public function queueDeclare($ticket = 1, $queue = '', $passive = false, $durable = false, $exclusive = false, $auto_delete = false, $nowait = false, $arguments = array())

    {

        $args = new AMQPWriter();

        $args->write_short($ticket);

        $args->write_shortstr($queue);

        $args->write_bits(array($passive, $durable, $exclusive, $auto_delete, $nowait));

        $args->write_table(empty($arguments) ? array() : $arguments);

        return array(50, 10, $args);

    }

    /**

     * @return array

     */

    public function exchangeDeclare($ticket = 0, $exchange, $type = 'direct', $passive = false, $durable = false, $auto_delete = false, $internal = false, $nowait = false, $arguments = array())

    {

        $args = new AMQPWriter();

        $args->write_short($ticket);

        $args->write_shortstr($exchange);

        $args->write_shortstr($type);

        $args->write_bits(array($passive, $durable, $auto_delete, $internal, $nowait));

        $args->write_table(empty($arguments) ? array() : $arguments);

        return array(40, 10, $args);

    }

    /**

     * @return array

     */

    public function queueDeclare($ticket = 0, $queue = '', $passive = false, $durable = false, $exclusive = false, $auto_delete = false, $nowait = false, $arguments = array())

    {

        $args = new AMQPWriter();

        $args->write_short($ticket);

        $args->write_shortstr($queue);

        $args->write_bits(array($passive, $durable, $exclusive, $auto_delete, $nowait));

        $args->write_table(empty($arguments) ? array() : $arguments);

        return array(50, 10, $args);

    }

    /**

     * @return array

     */

    public function basicConsume($ticket = 0, $queue = '', $consumer_tag = '', $no_local = false, $no_ack = false, $exclusive = false, $nowait = false, $arguments = array())

    {

        $args = new AMQPWriter();

        $args->write_short($ticket);

        $args->write_shortstr($queue);

        $args->write_shortstr($consumer_tag);

        $args->write_bits(array($no_local, $no_ack, $exclusive, $nowait));

        $args->write_table(empty($arguments) ? array() : $arguments);

        return array(60, 20, $args);

    }