TMV\Messenger\Factory\EventDispatcherFactory::__invoke()

Complexity

Conditions	4
Paths	8

Size

Total Lines	22
Code Lines	10

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	11
CRAP Score	4

Importance

Changes	1
Bugs	0	Features	0

<?php
    public function __invoke(ContainerInterface $container): EventDispatcherInterface
    {
        /** @var array $config */
        $config = $container->has('config') ? $container->get('config') : [];

        $eventDispatcher = new EventDispatcher();

        $eventDispatcher->addSubscriber($container->get(SendFailedMessageForRetryListener::class));

        $failureTransport = $config['messenger']['failure_transport'] ?? null;

        if ($failureTransport) {
            $eventDispatcher->addSubscriber($container->get(SendFailedMessageToFailureTransportListener::class));
        }

        $cachePoolForRestartSignal = $config['messenger']['cache_pool_for_restart_signal'] ?? null;

        if ($cachePoolForRestartSignal) {
            $eventDispatcher->addSubscriber($container->get(StopWorkerOnRestartSignalListener::class));
        }

        return $eventDispatcher;
    }