Antidot\Queue\Event\MessageReceived

Complexity

Total Complexity

1

Size/Duplication

Total Lines	15
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	1	Features	1

1 Method

Rating	Name	Duplication	Size	Complexity
A	occur()	0	13	1

<?php

declare(strict_types=1);

namespace Antidot\Queue\Event;

use Interop\Queue\Message;

final class MessageReceived extends QueueEvent
{
    public static function occur(Message $message): self
    {
        $self = new static();
        $self->payload = [
            'message_id' => $message->getMessageId(),
            'headers' => $message->getHeaders(),
            'body' => $message->getBody(),
            'properties' => $message->getProperties(),
            'reply_to' => $message->getReplyTo(),
            'timestamp' => $message->getTimestamp(),
        ];

        return $self;
    }
}