Chocofamily\LaravelEventSauce\ConsumerHandler

Complexity

Total Complexity

3

Size/Duplication

Total Lines	28
Duplicated Lines	0 %

Importance

Changes	2
Bugs	1	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	handle()	0	7	2

<?php

namespace Chocofamily\LaravelEventSauce;

use EventSauce\EventSourcing\Consumer as EventSauceConsumer;
use EventSauce\EventSourcing\Message;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Container\Container;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Queue\InteractsWithQueue;

final class ConsumerHandler implements ShouldQueue
{
    use InteractsWithQueue, Queueable;

    /** @var string */
    private $consumer;

    /** @var Message[] */
    private $messages = [];

    /**
     * ConsumerHandler constructor.
     * @param string $consumer
     * @param Message[] $messages
     */
    public function __construct(string $consumer, Message ...$messages)
    {
        $this->consumer = $consumer;
        $this->messages = $messages;
    }

    public function handle(Container $container): void
    {
        /** @var EventSauceConsumer $consumer */
        $consumer = $container->make($this->consumer);

        foreach ($this->messages as $message) {
            $consumer->handle($message);
        }
    }
}