Use symfony/messenger without supervisor

Symfony messenger use Supervisor to keep workers running but not all web hosting have a supervisor.

By default, the command will run forever and handle 10 messages before exiting with memory limit(128M) :

bin/console messenger:consume async --limit=10 --memory-limit=128M

To work around this problem, we will use cronjobs but we don't let workers run forever.
For that we will listen on the event WorkerRunningEvent :

<?php


namespace App\Event;

use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Symfony\Component\Messenger\Event\WorkerRunningEvent;

/**
 * Class ExtractFailedEvent
 * @package App\Event
 */
class CronRunningEvent implements EventSubscriberInterface
{
    public function onWorkerRunning(WorkerRunningEvent $event): void
    {
        if ($event->isWorkerIdle()) {
            $event->getWorker()->stop();
        }
    }

    /**
     * @return array<string>
     */
    public static function getSubscribedEvents()
    {
        return [
            WorkerRunningEvent::class => 'onWorkerRunning',
        ];
    }
}

Method isWorkerIdle() return true when no message has been received by the worker.
If no message has been received , we stop the worker

To finish, set up a cron job to run evry minute

* * * * * bin/console messenger:consume async --memory-limit=128M

Simple and easy!

Blog

Use symfony/messenger without supervisor

F.R Michel

Join Our Newsletter. No Spam, Only the good stuff.

Related