videlalvaro / php-amqplib

    /**

     * @return array

     */

    public function basicPublish($ticket = 1, $exchange = '', $routing_key = '', $mandatory = false, $immediate = false)

    {

        $args = new AMQPWriter();

        $args->write_short($ticket);

        $args->write_shortstr($exchange);

        $args->write_shortstr($routing_key);

        $args->write_bits(array($mandatory, $immediate));

        return array(60, 40, $args);

    }

    /**

     * @return array

     */

    public function filePublish($ticket = 1, $exchange = '', $routing_key = '', $mandatory = false, $immediate = false, $identifier)

    {

        $args = new AMQPWriter();

        $args->write_short($ticket);

        $args->write_shortstr($exchange);

        $args->write_shortstr($routing_key);

        $args->write_bits(array($mandatory, $immediate));

        $args->write_shortstr($identifier);

        return array(70, 60, $args);

    }

    /**

     * @return array

     */

    public function streamConsume($ticket = 1, $queue = '', $consumer_tag = '', $no_local = false, $exclusive = false, $nowait = false)

    {

        $args = new AMQPWriter();

        $args->write_short($ticket);

        $args->write_shortstr($queue);

        $args->write_shortstr($consumer_tag);

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

        return array(80, 20, $args);

    }

    /**

     * @return array

     */

    public function streamPublish($ticket = 1, $exchange = '', $routing_key = '', $mandatory = false, $immediate = false)

    {

        $args = new AMQPWriter();

        $args->write_short($ticket);

        $args->write_shortstr($exchange);

        $args->write_shortstr($routing_key);

        $args->write_bits(array($mandatory, $immediate));

        return array(80, 40, $args);

    }

    /**

     * @return array

     */

    public function basicPublish($ticket = 0, $exchange = '', $routing_key = '', $mandatory = false, $immediate = false)

    {

        $args = new AMQPWriter();

        $args->write_short($ticket);

        $args->write_shortstr($exchange);

        $args->write_shortstr($routing_key);

        $args->write_bits(array($mandatory, $immediate));

        return array(60, 40, $args);

    }