How to use Symfony’s Messenger component for queues?

Install Symfony Messenger component via Composer by running the following command in your terminal:

composer require symfony/messenger

Create a message class that represents the data you want to pass through the queue. For example, you could create a SendEmailMessage class with properties like to, subject, and body.
Create a handler class that will process the message when it is received from the queue. This class should implement MessageHandlerInterface and have a __invoke method to handle the message. For example, you could create a SendEmailHandler class with a __invoke(SendEmailMessage $message) method that sends the email.
Configure the Messenger component in your services.yaml file to map your message class to its respective handler class. For example:

services:
    App\Message\SendEmailHandler: ~

    messenger.transport_factory.default:
        class: 'Symfony\Component\Messenger\Transport\Sync\SyncTransportFactory'

    messenger.transport.default:
        dsn: 'sync://default'

Use the dispatch method of the MessageBusInterface service to send a message to the queue. For example:

$this->messageBus->dispatch(new SendEmailMessage('[email protected]', 'Hello', 'This is a test email'));

Run the Messenger worker to listen for and process messages in the queue. You can start the worker by running the following command in your terminal:

php bin/console messenger:consume

Your message will be processed by the appropriate handler class once it reaches the front of the queue. You can monitor the progress and any errors in the processing by checking the logs or by adding logging statements to your handler class.