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

Complexity

Conditions	3
Paths	2

Size

Total Lines	16
Code Lines	11

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	11
CRAP Score	3

Importance

Changes

0

<?php
    public function deliver(MessageInterface $message, callable $next): void
    {
        if ($this->entityManager->getConnection()->isTransactionActive()) {
            $next($message);

            return;
        }

        try {
            $this->entityManager->beginTransaction();
            $next($message);
            $this->entityManager->flush();
            $this->entityManager->commit();
        } catch (Exception $exception) {
            $this->entityManager->rollback();
            throw $exception;
        }