TomCizek\SymfonyProoph\Tests\AsynchronousMessages\FakeImplementations\TestAsynchronousMessageProducerBridge

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\SymfonyProoph\Tests\AsynchronousMessages\FakeImplementations;

use Prooph\Common\Messaging\Message;
use TomCizek\SymfonyProoph\AsynchronousMessages\AsynchronousMessageProducerBridge;

class TestAsynchronousMessageProducerBridge 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;
	}
}