src/AbstractConsumer.php
protected function handleProcessFlag(Envelope $envelope, DeliveryResult $flag)
    {
        $this->countMessagesConsumed++;

        switch ($flag) {
            case DeliveryResult::MSG_REJECT():
                $this->queue->nack($envelope->getDeliveryTag(), Constants::AMQP_NOPARAM);
                $this->logger->debug('Rejected message', $this->extractMessageInformation($envelope));
                break;
            case DeliveryResult::MSG_REJECT_REQUEUE():
                $this->queue->nack($envelope->getDeliveryTag(), Constants::AMQP_REQUEUE);
                $this->logger->debug('Rejected and requeued message', $this->extractMessageInformation($envelope));
                break;
            case DeliveryResult::MSG_ACK():
                $this->countMessagesUnacked++;
                $this->lastDeliveryTag = $envelope->getDeliveryTag();
                $this->timestampLastMessage = microtime(true);
                $this->ack();
                break;
            case DeliveryResult::MSG_DEFER():
                $this->countMessagesUnacked++;
                $this->lastDeliveryTag = $envelope->getDeliveryTag();
                $this->timestampLastMessage = microtime(true);
                break;
        }
    }
protected function handleProcessFlag(Envelope $envelope, DeliveryResult $flag)
    {
        $this->countMessagesConsumed++;

        switch ($flag) {
            case DeliveryResult::MSG_REJECT():
                $this->queue->nack($envelope->getDeliveryTag(), Constants::AMQP_NOPARAM);
                $this->logger->debug('Rejected message', $this->extractMessageInformation($envelope));
                break;
            case DeliveryResult::MSG_REJECT_REQUEUE():
                $this->queue->nack($envelope->getDeliveryTag(), Constants::AMQP_REQUEUE);
                $this->logger->debug('Rejected and requeued message', $this->extractMessageInformation($envelope));
                break;
            case DeliveryResult::MSG_ACK():
                $this->countMessagesUnacked++;
                $this->lastDeliveryTag = $envelope->getDeliveryTag();
                $this->timestampLastMessage = microtime(true);
                $this->ack();
                break;
            case DeliveryResult::MSG_DEFER():
                $this->countMessagesUnacked++;
                $this->lastDeliveryTag = $envelope->getDeliveryTag();
                $this->timestampLastMessage = microtime(true);
                break;
        }
    }
protected function handleProcessFlag ( Envelope $ envelope , DeliveryResult $ flag ) { $ this -> countMessagesConsumed ++ ; switch ( $ flag ) { case DeliveryResult :: MSG_REJECT ( ) : $ this -> queue -> nack ( $ envelope -> getDeliveryTag ( ) , Constants :: AMQP_NOPARAM ) ; $ this -> logger -> debug ( 'Rejected message' , $ this -> extractMessageInformation ( $ envelope ) ) ; break ; case DeliveryResult :: MSG_REJECT_REQUEUE ( ) : $ this -> queue -> nack ( $ envelope -> getDeliveryTag ( ) , Constants :: AMQP_REQUEUE ) ; $ this -> logger -> debug ( 'Rejected and requeued message' , $ this -> extractMessageInformation ( $ envelope ) ) ; break ; case DeliveryResult :: MSG_ACK ( ) : $ this -> countMessagesUnacked ++ ; $ this -> lastDeliveryTag = $ envelope -> getDeliveryTag ( ) ; $ this -> timestampLastMessage = microtime ( true ) ; $ this -> ack ( ) ; break ; case DeliveryResult :: MSG_DEFER ( ) : $ this -> countMessagesUnacked ++ ; $ this -> lastDeliveryTag = $ envelope -> getDeliveryTag ( ) ; $ this -> timestampLastMessage = microtime ( true ) ; break ; } }
Handle process flag

@param Envelope $envelope
@param $flag
@return void
Handle process flag