asynchronous-messaging-04.php

asynchronous-messaging-04.php

<?php

$bus->dispatch(new PlaceOrder(), [new ExecutorStamp($executorId)]);

(..)

class AuthorizeExecutorMiddleware implements MiddlewareInterface
{
    public function handle(Envelope $envelope, StackInterface $stack): Envelope
    {
        $stamps = $envelope->all(ExecutorStamp::class);
      
        // do something more
      
        return $stack->next()->handle($envelope, $stack);
    }
}