Werkspot\MessageBus\Bus\DeliveryChain\Middleware\AsynchronousDeliveryMiddleware::deliver()

Complexity

Conditions	2
Paths	2

Size

Total Lines	13
Code Lines	4

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	5
CRAP Score	2

Importance

Changes

0

<?php
    public function deliver(MessageInterface $message, callable $next): void
    {
        if ($message instanceof AsynchronousMessageInterface) {
            // By default we 'queue' all QueuedMessage, even if the execute_at is in the past.
            // We do this  so that we support transactions and can rollback the execution if something goes wrong in
            // another part of the transaction.
            // If we were to send it to rabbit in the Async middleware, and further on an exception occurs, if would
            // already have been processed using rabbit, and there's no way to roll it back.
            $this->messageQueueService->enqueueMessage($message);
            return;
        }

        $next($message);
    }