Innmind\AMQP\Client\Channel\Basic\Get\Logger::__invoke()

Complexity

Conditions	4
Paths	1

Size

Total Lines	34
Code Lines	23

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	22
CRAP Score	4

Importance

Changes

0

<?php
    public function __invoke(callable $consume): void
    {
        ($this->get)(function(Message $message, ...$args) use ($consume): void {
            try {
                $this->logger->debug(
                    'AMQP message received',
                    ['body' => (string) $message->body()]
                );

                $consume($message, ...$args);
            } catch (Reject $e) {
                $this->logger->warning(
                    'AMQP message rejected',
                    ['body' => (string) $message->body()]
                );
                throw $e;
            } catch (Requeue $e) {
                $this->logger->info(
                    'AMQP message requeued',
                    ['body' => (string) $message->body()]
                );
                throw $e;
            } catch (\Throwable $e) {
                $this->logger->error(
                    'AMQP message consumption generated an exception',
                    [
                        'body' => (string) $message->body(),
                        'exception' => get_class($e),
                    ]
                );
                throw $e;
            }
        });
    }
}