TomCizek\AsynchronousRouter\Tests\DependencyInjection\Fixture\Model\AbstractTestAsynchronousMessageProducerBridge

Complexity

Total Complexity

2

Size/Duplication

Total Lines	20
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	publishWithRoutingKey()	0	7	1
A	getPublished()	0	4	1

<?php

declare(strict_types = 1);

namespace TomCizek\AsynchronousRouter\Tests\DependencyInjection\Fixture\Model;

use Prooph\Common\Messaging\Message;
use TomCizek\AsynchronousRouter\AsynchronousMessageProducerBridge;

class AbstractTestAsynchronousMessageProducerBridge implements AsynchronousMessageProducerBridge
{
    public const KEY_ROUTING_KEY = 'routingKey';
    public const KEY_MESSAGE = 'message';

    private $published = [];

    public function publishWithRoutingKey(Message $message, string $routingKey): void
    {
        $this->published[] = [
            self::KEY_ROUTING_KEY => $routingKey,
            self::KEY_MESSAGE => $message,
        ];
    }

    public function getPublished()
    {
        return $this->published;
    }
}