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);
    }
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);
    }
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 ) ; }
Reject the message and requeue it.

@see ConsumerOptionsInterface::$noAck to consume messages without requiring
excplicit acknowledgement by the consumer.

@param bool $requeue
@throws \InvalidArgumentException
@throws \PHPDaemon\Clients\AMQP\Driver\Protocol\Exception\AMQPProtocolException
@throws \PHPDaemon\Clients\AMQP\Driver\Exception\AMQPMessageException
Reject the message and requeue it .