Message Queue

See https://symfony.com/doc/current/messenger.html for details.

To queue a message to be handled later inject the MessageBusInterface into your service and dispatch your message:

$message = new GuestCheckOutMessage();
$bus->dispatch($message);

Registering a Message Class for the Global Message Queue

Register a message class, so when it gets dispatched it gets handled by the global async message queue.

public function prepend(ContainerBuilder $container)
{
    $this->addQueueMessage($container, GuestCheckOutMessage::class);
    // ...

Error Handling in the Message Handler

By default the worker queue will try to handle the message up to 3 times in case it throws an error. If you want to customize the retry behavior you can either throw a UnrecoverableMessageHandlingException or a RecoverableMessageHandlingException, see https://symfony.com/doc/current/messenger.html#retries-failures for details.

After 3 times it the message will be moved to the async_failed transport and you can inspect and retry it manually, see https://symfony.com/doc/current/messenger.html#saving-retrying-failed-messages for details.