src/AbstractConsumer.php
protected function ack()
    {
        $this->queue->ack($this->lastDeliveryTag, Constants::AMQP_MULTIPLE);
        $this->lastDeliveryTag = null;
        $delta = $this->timestampLastMessage - $this->timestampLastAck;

        $this->logger->info(sprintf(
            'Acknowledged %d messages at %.0f msg/s',
            $this->countMessagesUnacked,
            $delta ? $this->countMessagesUnacked / $delta : 0
        ));

        $this->timestampLastAck = microtime(true);
        $this->countMessagesUnacked = 0;
    }
protected function ack()
    {
        $this->queue->ack($this->lastDeliveryTag, Constants::AMQP_MULTIPLE);
        $this->lastDeliveryTag = null;
        $delta = $this->timestampLastMessage - $this->timestampLastAck;

        $this->logger->info(sprintf(
            'Acknowledged %d messages at %.0f msg/s',
            $this->countMessagesUnacked,
            $delta ? $this->countMessagesUnacked / $delta : 0
        ));

        $this->timestampLastAck = microtime(true);
        $this->countMessagesUnacked = 0;
    }
protected function ack ( ) { $ this -> queue -> ack ( $ this -> lastDeliveryTag , Constants :: AMQP_MULTIPLE ) ; $ this -> lastDeliveryTag = null ; $ delta = $ this -> timestampLastMessage - $ this -> timestampLastAck ; $ this -> logger -> info ( sprintf ( 'Acknowledged %d messages at %.0f msg/s' , $ this -> countMessagesUnacked , $ delta ? $ this -> countMessagesUnacked / $ delta : 0 ) ) ; $ this -> timestampLastAck = microtime ( true ) ; $ this -> countMessagesUnacked = 0 ; }
Acknowledge all deferred messages

This will be called every time the block size (see prefetch_count) or timeout is reached

@return void
Acknowledge all deferred messages