for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?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;
tomcizek /
symfony-prooph-asynchronous-router
