CallbackScheduleProvider

CallbackScheduleProvider.php

<?php

namespace App\Scheduler;

use App\Message\WatchDogMessage;
use Symfony\Component\Scheduler\Schedule;
use Symfony\Component\Scheduler\RecurringMessage;
use Symfony\Component\Scheduler\Attribute\AsSchedule;
use Symfony\Component\Scheduler\ScheduleProviderInterface;
use Symfony\Component\Scheduler\Trigger\CallbackTrigger;

#[AsSchedule('callback')]
class CallbackScheduleProvider implements ScheduleProviderInterface
{
    static $count = 0;
    public function getSchedule(): Schedule
    {
        $trigger = new CallbackTrigger(function() {
            return (new \DateTimeImmutable('now'))->modify(sprintf('+%d seconds', ++static::$count));
        });

        return (new Schedule())->add(
            RecurringMessage::trigger($trigger,  new WatchDogMessage(['logger', 'imports', 'exports']))
        );
    }
}