php-background-job-gist9.php

<?php
use Bernard\Router\ClassNameRouter;
use Bernard\Consumer;
use Bernard\Queue\RoundRobinQueue;
use Bernard\Message;

/** @var Psr\Container\ContainerInterface */
$conatiner = ...
  
$router = new ClassNameRouter();

$router->add(Message::class, function($message) use ($handlers) {
  $handlerClass = $handlers[$message->getName()];
  $handler = $conatiner->get($handlerClass);
  $handler($messsage);
});

// Create a Consumer and start the loop.
$consumer = new Consumer($router, $eventDispatcher);