diff --git a/src/MessageHandler/ProcessDomainTriggerHandler.php b/src/MessageHandler/ProcessDomainTriggerHandler.php index c29d287..eebf90f 100644 --- a/src/MessageHandler/ProcessDomainTriggerHandler.php +++ b/src/MessageHandler/ProcessDomainTriggerHandler.php @@ -62,7 +62,7 @@ final readonly class ProcessDomainTriggerHandler } /** @var DomainEvent $event */ - foreach ($domain->getEvents()->filter(fn ($event) => $message->updatedAt < $event->getDate()) as $event) { + foreach ($domain->getEvents()->filter(fn ($event) => $message->updatedAt < $event->getDate() && $event->getDate() < new \DateTime()) as $event) { $watchListTriggers = $watchList->getWatchListTriggers() ->filter(fn ($trigger) => $trigger->getEvent() === $event->getAction());