src/AbstractConsumer.php
protected function ackOrNackBlock()
    {
        if (! $this->lastDeliveryTag) {
            return;
        }

        $result = $this->flushDeferred();

        switch ($result) {
            case FlushDeferredResult::MSG_ACK():
                $this->ack();
                break;
            case FlushDeferredResult::MSG_REJECT():
                $this->nackAll(false);
                break;
            case FlushDeferredResult::MSG_REJECT_REQUEUE():
                $this->nackAll(true);
                break;
        }
    }
protected function ackOrNackBlock()
    {
        if (! $this->lastDeliveryTag) {
            return;
        }

        $result = $this->flushDeferred();

        switch ($result) {
            case FlushDeferredResult::MSG_ACK():
                $this->ack();
                break;
            case FlushDeferredResult::MSG_REJECT():
                $this->nackAll(false);
                break;
            case FlushDeferredResult::MSG_REJECT_REQUEUE():
                $this->nackAll(true);
                break;
        }
    }
protected function ackOrNackBlock ( ) { if ( ! $ this -> lastDeliveryTag ) { return ; } $ result = $ this -> flushDeferred ( ) ; switch ( $ result ) { case FlushDeferredResult :: MSG_ACK ( ) : $ this -> ack ( ) ; break ; case FlushDeferredResult :: MSG_REJECT ( ) : $ this -> nackAll ( false ) ; break ; case FlushDeferredResult :: MSG_REJECT_REQUEUE ( ) : $ this -> nackAll ( true ) ; break ; } }
Handle deferred acknowledgments

@return void
Handle deferred acknowledgments