Vue d'ensemble…

Configuration messenger.yaml

                            
framework:
    messenger:
        transports:
            default: '%env(MESSENGER_ADAPTER_DSN)%'

        routing:
            # Route your messages to the transports
                            
                        

… sur la bonne route !

                            
framework:
    messenger:
        transports:
            default: enqueue://redis
            log: enqueue://file

        routing:
            'App\Domain\Exam\Message\DeleteExamFromSearch': [default, log]
            '*': default
                            
                        

Middlewares

                            
namespace Symfony\Component\Messenger\Middleware;

interface MiddlewareInterface
{
    public function handle($message, callable $next);
}
                            
                        

                            
use Psr\Log\LoggerInterface;
use Symfony\Component\Messenger\Middleware\MiddlewareInterface;

class LoggingMiddleware implements MiddlewareInterface
{
    private $logger;

    public function __construct(LoggerInterface $logger)
    {
        $this->logger = $logger;
    }

    public function handle($message, callable $next)
    {
        $this->logger->debug(
            'Starting handling message {class}',
            get_class($message)
        );
        return $next($message);
    }
}
                            
                        

Configuration

                            
# config/packages/messenger.yaml
framework:
    messenger:
        buses:
            messenger.bus.default:
                middleware:
                    - 'App\Middleware\LoggingMiddleware'