EventSauce\EventSourcing\TestUtilities\TestingMessageConsumers\TestedMessageConsumer

Complexity

Total Complexity

4

Size/Duplication

Total Lines	27
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

3 Methods

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

<?php

declare(strict_types=1);

namespace EventSauce\EventSourcing\TestUtilities\TestingMessageConsumers;

use EventSauce\EventSourcing\Message;
use EventSauce\EventSourcing\MessageConsumer;
use LogicException;

class TestedMessageConsumer implements MessageConsumer
{
    /**
     * @var int
     */
    private $failAfterNumberOfMessages;

    /**
     * @var int
     */
    private $numberOfMessagesProcessed = 0;

    public function __construct(int $failAfterNumberOfMessages)
    {
        $this->failAfterNumberOfMessages = $failAfterNumberOfMessages;
    }

    public function handle(Message $message): void
    {
        if (++$this->numberOfMessagesProcessed === $this->failAfterNumberOfMessages) {
            throw new LogicException('Too many messages');
        }
    }

    public function numberOfMessagesProcessed(): int
    {
        return $this->numberOfMessagesProcessed;
    }
}