Kreta\SharedKernel\Infrastructure\Messaging\AMQP\PhpAmqpLib\Consumer::execute()

Complexity

Conditions	3
Paths	3

Size

Total Lines	26
Code Lines	16

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function execute(AMQPMessage $message)
    {
        $body = json_decode($message->body);
        if ($this->messageName !== $body->name) {
            return false;
        }

        try {
            $this->eventSubscriber->handle(
                new AsyncEvent(
                    $this->messageName,
                    new \DateTimeImmutable($body->occurredOn),
                    json_decode(
                        json_encode(
                            $body->values
                        ),
                        true
                    )
                )
            );

            return self::MSG_ACK;
        } catch (Exception $exception) {
            return self::MSG_REJECT;
        }
    }
}