Xervice\EventRabbitMq\Communication\Plugin\EventProvider\RabbitMqEventProvider

Complexity

Total Complexity

1

Size/Duplication

Total Lines	15
Duplicated Lines	0 %

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
A	provideEvent()	0	8	1

<?php


namespace Xervice\EventRabbitMq\Communication\Plugin\EventProvider;


use DataProvider\EventDataProvider;
use DataProvider\RabbitMqMessageDataProvider;
use Xervice\Core\Locator\AbstractWithLocator;

The type Xervice\Core\Locator\AbstractWithLocator was not found. Maybe you did not declare it correctly or list all dependencies?

use Xervice\Event\Business\Provider\EventProviderInterface;

The type Xervice\Event\Business\Provider\EventProviderInterface was not found. Maybe you did not declare it correctly or list all dependencies?

/**
 * @method \Xervice\EventRabbitMq\EventRabbitMqFactory getFactory()
 */
class RabbitMqEventProvider extends AbstractWithLocator implements EventProviderInterface
{
    /**
     * @param \DataProvider\EventDataProvider $eventDataProvider
     *
     * @throws \Core\Locator\Dynamic\ServiceNotParseable
     */
    public function provideEvent(EventDataProvider $eventDataProvider): void
    {
        $message = new RabbitMqMessageDataProvider();
        $message
            ->setExchange($this->getFactory()->createEventExchange())
            ->setMessage($eventDataProvider);

        $this->getFactory()->getRabbitMqClient()->sendMessage($message);
    }
}