happyr/bref-messenger-failure-strategies

Make sure you can use Bref Symfony Messenger failure strategies

0.5.0 2024-03-13 18:15 UTC

Requires

• php: >=7.3
• bref/symfony-messenger: ^0.3 || ^0.4 || ^0.5 || ^1.0
• symfony/messenger: ^4.4 || ^5.0 || ^6.0 || ^7.0

Requires (Dev)

• phpunit/phpunit: ^8.5.31
• symfony/event-dispatcher-contracts: ^2.0
• symfony/polyfill-php80: ^1.17
• symfony/validator: ^5.0 || ^6.0 || ^7.0

MIT

• Tobias Nyholm

README

So you have fallen in love with Bref and you really want to use Symfony's excellent Messenger component. You've probably also installed the Bref Symfony Messenger bundle that allows you to publish messages on SQS and SNS etc. But you are missing something... You want to be able to use Symfony Messenger retry strategies, right?

This is the package for you!

Install

composer require happyr/bref-messenger-failure-strategies

Now you have a class called Happyr\BrefMessenger\SymfonyBusDriver that implements Bref\Symfony\Messenger\Service\BusDriver. Feel free to configure your consumers with this new class.

Example

On each consumer you can choose to let Symfony handle failures as described in the documentation.

# config/packages/messenger.yaml

framework:
    messenger:
        failure_transport: failed
        transports:
            failed: 'doctrine://default?queue_name=failed'
            workqueue:
              dsn: 'https://sqs.us-east-1.amazonaws.com/123456789/my-queue'
              retry_strategy:
                  max_retries: 3
                  # milliseconds delay
                  delay: 1000
                  multiplier: 2
                  max_delay: 60

services:
    Happyr\BrefMessenger\ExceptionLogger:
        autowire: true
        autoconfigure: true

    Happyr\BrefMessenger\SymfonyBusDriver:
        autowire: true

    Bref\Symfony\Messenger\Service\Sqs\SqsConsumer:
        arguments:
            - '@Happyr\BrefMessenger\SymfonyBusDriver'
            - '@messenger.routable_message_bus'
            - '@Symfony\Component\Messenger\Transport\Serialization\SerializerInterface'
            - 'my_sqs' # Same as transport name

# ...

The delay is only supported on SQS "normal queue". If you are using SNS or SQS FIFO you should use the failure queue directly.

# config/packages/messenger.yaml

framework:
    messenger:
        failure_transport: failed
        transports:
            failed: 'doctrine://default?queue_name=failed'
            workqueue:
              dsn: 'sns://arn:aws:sns:us-east-1:1234567890:foobar'
              retry_strategy:
                  max_retries: 0
services:
    # ...

Make sure you re-run the failure queue time to time. The following config will run a script for 5 seconds every 30 minutes. It will run for 5 seconds even though no messages has failed.

# serverless.yml

functions:
    website:
        # ...
    consumer:
        # ...

    console:
        handler: bin/console
        Timeout: 120 # in seconds
        layers:
            - ${bref:layer.php-74}
            - ${bref:layer.console}
        events:
            - schedule:
                  rate: rate(30 minutes)
                  input:
                      cli: messenger:consume failed --time-limit=5 --limit=50