Simple Event Scheduler

v0.1.0 2017-07-26 15:41 UTC

This package is auto-updated.

Last update: 2023-11-14 17:50:11 UTC


Simple Event scheduler for the Neos.EventSourcing Flow package


class SomeClass implements EventListenerInterface
    const TASK_TYPE = 'plans';

     * @Flow\Inject
     * @var EventScheduler
    protected $scheduler;

    public function whenSomeThingWasPlanned(SomeThingWasPlanned $event): void
        $taskPayload = ['nameOfTheThing' => $event->getTitle()];
        $this->scheduler->scheduleTask($event->getCorrelationId(), self::TASK_TYPE, $event->getPlannedDate(), $taskPayload);

    public function whenSomeThingWasCancelled(SomeThingWasCancelled $event): void
        $this->scheduler->cancelTask($event->getCorrelationId(), self::TASK_TYPE);

    public function whenSchedulerWasTriggered(SchedulerWasTriggered $event): void
        if (!$event->matchesType(self::TASK_TYPE)) {
        $payload = $event->getPayload();

        // TODO Do something with the $paload

To make this work the ./flow wwwision.eventscheduler:scheduler:run command needs to be executed regularly (e.g. via cron)

Note: In this example SomeThingWasPlanned and SomeThingWasCancelled are domain events. SchedulerWasTriggered is an "integration event" that triggered by the EventScheduler as soon as the given timestamp is reached.