kakserpom / phpdaemon

     * @throws \InvalidArgumentException

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

     */

    public function nack($multiple = null, $requeue = null)

    {

        $this->checkChannel();

        $outputFrame = BasicNackFrame::create($this->tag, $multiple, $requeue);

        $outputFrame->frameChannelId = $this->channel->getId();

        $this->channel->getConnection()->command($outputFrame);

    }

    /**

     * Reject the message and requeue it.

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

     * @throws \PHPDaemon\Clients\AMQP\Driver\Exception\AMQPMessageException

     */

    public function reject($requeue = true)

    {

        $this->checkChannel();

        $outputFrame = BasicRejectFrame::create($this->tag, $requeue);

        $outputFrame->frameChannelId = $this->channel->getId();

        if (null !== $requeue) {

            $outputFrame->requeue = $requeue;

        }

        $this->channel->getConnection()->command($outputFrame);

    }

    /**

     * Get the length of the message content, in bytes.