for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
declare(strict_types=1);
namespace Damax\Common\Domain\EventPublisher;
use SimpleBus\Message\Bus\MessageBus;
use SimpleBus\Message\Recorder\ContainsRecordedMessages;
final class SimpleBusEventPublisher implements EventPublisher
{
private $recorder;
private $eventBus;
public function __construct(ContainsRecordedMessages $recorder, MessageBus $eventBus)
$this->recorder = $recorder;
$this->eventBus = $eventBus;
}
public function publish(): void
$eventStream = $this->recorder->recordedMessages();
if (!count($eventStream)) {
return;
$this->recorder->eraseMessages();
foreach ($eventStream as $event) {
$this->eventBus->handle($event);
public function discard(): void
damax-solutions /
common
