New in Symfony 4.3: Messenger failure transport

May 3, 2019 Javier Eguiluz

The Messenger component provides a retry mechanism for messages. In Symfony 4.3 we've improved this feature to add a "failure" transport, so that messages that fail on all their retries can be collected in one spot and retried later if wanted.

Consider the following configuration:

framework:
    messenger:
        failure_transport: failed

        transports:
            async:
                dsn: 'amqp://'
            failed:
                dsn: 'doctrine://default?queue_name=failed'

        routing:
            'App\Message\SmsNotification': async

In this setup, SmsNotification would be retried three times on the async transport and then finally sent to the failed transport. You can consume the failed transport like a normal transport, but you should handle and consume it by one of these new commands:

$ php bin/console messenger:failed:show

  There are 3 messages waiting in the failed transport.

  ---  ---------------------------  -------------------  -----
  Id   Class                        Failed at            Error
  ---  ---------------------------  -------------------  -----
  217  App\Message\SmsNotification  2019-04-10 22:12:01  ...
  218  App\Message\SmsNotification  2019-04-10 22:12:00  ...
  219  App\Message\SmsNotification  2019-04-10 22:11:59  ...
  ---  ---------------------------  -------------------  -----

  // Run "messenger:failed:show {id} -vv" to see message details

$ php bin/console messenger:failed:show 217

  There are 3 messages waiting in the failed transport.

  -----------  ---------------------------
  Class        App\Message\SmsNotification
  Message Id   217
  Failed at    2019-04-10 22:12:01
  Error        ...
  Error Class  Exception
  Transport    async
  -----------  ---------------------------

  Re-run command with "-vv" to see more message & error details.

  Run "messenger:failed:retry 217" to retry this message.
  Run "messenger:failed:purge 217" to delete it.

New in Symfony 4.3: Messenger failure transport symfony.com/blog/new-in-symfony-4-3-messenger-failure-transport

Tweet this

Comments

Tac Tacelosky said on May 3, 2019 at 13:42 #1

This looks great! Can you describe how to configure the

dsn: 'doctrine://default?queue_name=failed'

I'm not familiar with this syntax for doctrine.

Ksaveras Šakys Certified said on May 3, 2019 at 14:50 #2

Fantastic, thanks for this feature!

Javier Eguiluz said on May 3, 2019 at 16:58 #3

@Tac the syntax for the Messenger Doctrine transport is explained in this Symfony Docs pull request pending to be merged:

https://github.com/symfony/symfony-docs/pull/10616/files

Laurent VOULLEMIER said on May 3, 2019 at 19:50 #4

Great ! Thank you :)

Tien Vo said on May 6, 2019 at 08:54 #5

Nice feature! Thank you!

btw, ^ (the above comment): is it related to Symfony?