for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
namespace HMLB\DDDBundle\MessageBus\Middleware;
use HMLB\DDD\Exception\Exception;
use HMLB\DDDBundle\EventListener\CollectsEventsFromEntities;
use Psr\Log\LoggerInterface;
use SimpleBus\Message\Bus\Middleware\MessageBusMiddleware;
/**
* This subscribers throws an exception if DomainEvents have been collected and will not be notified.
*
* It should have High priority to check for Events after all Notifiers like "NotifiesDomainEvents" have been called.
* @author Hugues Maignol <[email protected]>
*/
class MonitorsDomainEvents implements MessageBusMiddleware
{
* @var CollectsEventsFromEntities
private $collectsEventsFromEntities;
* @var LoggerInterface
private $logger;
* @param LoggerInterface $logger
* @param CollectsEventsFromEntities $collectsEventsFromEntities
public function __construct(
LoggerInterface $logger,
CollectsEventsFromEntities $collectsEventsFromEntities
) {
$this->logger = $logger;
$this->collectsEventsFromEntities = $collectsEventsFromEntities;
}
* @param object $message
* @param callable $next
* @throws Exception
public function handle($message, callable $next)
$next($message);
$events = $this->collectsEventsFromEntities->recordedMessages();
$count = count($events);
$this->logger->debug('MonitorsDomainEvents saw '.$count.' events');
if ($count) {
throw new Exception(
sprintf(
'%s Domain Events have been collected but will not be notified.
You should not raise domain event during the handling of a Event message but only for a Command.'
)
);
hmlb /
ddd-bundle
