asynchronous-messaging-02.php

asynchronous-messaging-02.php

<?php
# config/packages/messenger.yaml
framework:
    messenger:
        buses:
            messenger.bus.default:
                middleware:
                    - 'AddExecutorIdMiddleware'
                      
class AddExecutorIdMiddleware implements MiddlewareInterface
{
    public function handle(Envelope $envelope, StackInterface $stack): Envelope
    {
        // You may change the Message here or add addtional behaviour.
        $envelope = $envelope->with(new ExecutorStamp($id));
 
        // Or stop execution by not calling next.
        return $stack->next()->handle($envelope, $stack);
    }
}