Jellyfish\Event\EventQueueProducer

Complexity

Total Complexity

2

Size/Duplication

Total Lines	49
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
A	enqueue()	0	12	1

<?php

declare(strict_types=1);

namespace Jellyfish\Event;

use Jellyfish\Queue\DestinationFactoryInterface;
use Jellyfish\Queue\DestinationInterface;
use Jellyfish\Queue\QueueClientInterface;

class EventQueueProducer implements EventQueueProducerInterface
{
    /**
     * @var \Jellyfish\Event\EventMapperInterface
     */
    protected $eventMapper;

    /**
     * @var \Jellyfish\Queue\QueueClientInterface
     */
    protected $queueClient;

    /**
     * @var \Jellyfish\Queue\DestinationFactoryInterface
     */
    protected $destinationFactory;

    /**
     * @param \Jellyfish\Event\EventMapperInterface $eventMapper
     * @param \Jellyfish\Queue\QueueClientInterface $queueClient
     * @param \Jellyfish\Queue\DestinationFactoryInterface $destinationFactory
     */
    public function __construct(
        EventMapperInterface $eventMapper,
        QueueClientInterface $queueClient,
        DestinationFactoryInterface $destinationFactory
    ) {
        $this->eventMapper = $eventMapper;
        $this->queueClient = $queueClient;
        $this->destinationFactory = $destinationFactory;
    }

    /**
     * @param \Jellyfish\Event\EventInterface $event
     *
     * @return \Jellyfish\Event\EventQueueProducerInterface
     */
    public function enqueue(
        EventInterface $event
    ): EventQueueProducerInterface {
        $destination = $this->destinationFactory->create()
            ->setName($event->getName())
            ->setType(DestinationInterface::TYPE_FANOUT);

        $message = $this->eventMapper->toMessage($event);

        $this->queueClient->sendMessage($destination, $message);

        return $this;
    }
}