Mouf\AmqpClient\AbstractConsumer::callback()

Complexity

Conditions	5
Paths	9

Size

Total Lines	24
Code Lines	16

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function callback($msg)
    {
        try {
            $this->onMessageReceived($msg);

            $msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);
        } catch (RetryableExceptionInterface $e) {
            $this->logger->error("Exception caught while consuming message.", [
                'exception' => $e
            ]);
            if ($e instanceof FatalExceptionInterface) {
                throw $e;
            }
            $msg->delivery_info['channel']->basic_nack($msg->delivery_info['delivery_tag'], true, true);
        } catch (\Exception $e) {
            $this->logger->error("Exception caught while consuming message.", [
                'exception' => $e
            ]);
            if ($e instanceof FatalExceptionInterface) {
                throw $e;
            }
            $msg->delivery_info['channel']->basic_nack($msg->delivery_info['delivery_tag'], true, false);
        }
    }