Workana\AsyncJobs\EventDispatching\FailoverEventDispatcher

Complexity

Total Complexity

6

Size/Duplication

Total Lines	33
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	3

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
B	doDispatch()	0	25	6

<?php
namespace Workana\AsyncJobs\EventDispatching;

use Exception;
use Throwable;
use Symfony\Component\EventDispatcher\EventDispatcher;
use Symfony\Component\EventDispatcher\Event;

/**
 * Failover event dispatcher
 *
 * @author Carlos Frutos <charly@workana.com>
 */
class FailoverEventDispatcher extends EventDispatcher
{
    /**
     * {@inheritDoc}
     *
     * @throws AggregateRootEventException
     */
    protected function doDispatch($listeners, $eventName, Event $event)
    {
        /**
         * Array of arrays of type [$callable, $reason]
         */
        $failedListeners = [];

        foreach ($listeners as $listener) {
            try {
                call_user_func($listener, $event, $eventName, $this);
            } catch (Throwable $t) {

The class Throwable does not exist. Is this class maybe located in a folder that is not analyzed, or in a newer version of your dependencies than listed in your composer.lock/composer.json?

                $failedListeners[] = [$listener, $t];
            } catch (Exception $e) {
                $failedListeners[] = [$listener, $e];
            }
            
            if ($event->isPropagationStopped()) {
                break;
            }
        }

        if (!empty($failedListeners)) {
            throw new AggregateRootEventException($eventName, $event, $failedListeners);
        }
    }
}