kakserpom / phpdaemon

     * @throws \InvalidArgumentException

     * @throws \PHPDaemon\Clients\AMQP\Driver\Protocol\Exception\AMQPProtocolException

     */

    public function cancel($consumerTag, array $options = [])

    {

        $noWait = array_key_exists('noWait', $options) ? $options['noWait'] : null;

        $outputFrame = Basic\BasicCancelFrame::create($consumerTag, $noWait);

        $outputFrame->frameChannelId = $this->id;

        $this->connection->command($outputFrame);

    }

    /**

     * get message from queue

     * @throws \InvalidArgumentException

     * @throws \PHPDaemon\Clients\AMQP\Driver\Protocol\Exception\AMQPProtocolException

     */

    public function ack($deliveryTag, array $options = [])

    {

        $multiple = array_key_exists('multiple', $options) ? (int)$options['multiple'] : null;

        $outputFrame = Basic\BasicAckFrame::create($deliveryTag, $multiple);

        $outputFrame->frameChannelId = $this->id;

        $this->connection->command($outputFrame);

    }

    /**

     * Nack message

     * @throws \InvalidArgumentException

     * @throws \PHPDaemon\Clients\AMQP\Driver\Protocol\Exception\AMQPProtocolException

     */

    public function reject($deliveryTag, array $options = [])

    {

        $requeue = array_key_exists('requeue', $options) ? $options['requeue'] : null;

        $outputFrame = Basic\BasicRejectFrame::create($deliveryTag, $requeue);

        $outputFrame->frameChannelId = $this->id;

        $this->connection->command($outputFrame);

    }

    /**

     * Redeliver unacknowledged messages.