PHPackages happyr/bref-messenger-failure-strategies - PHPackages - PHPackages [Skip to content](#main-content)[PHPackages](/)[Directory](/)[Categories](/categories)[Trending](/trending)[Leaderboard](/leaderboard)[Changelog](/changelog)[Analyze](/analyze)[Collections](/collections)[Log in](/login)[Sign up](/register) 1. [Directory](/) 2. / 3. [Queues & Workers](/categories/queues) 4. / 5. happyr/bref-messenger-failure-strategies ActiveLibrary[Queues & Workers](/categories/queues) happyr/bref-messenger-failure-strategies ======================================== Make sure you can use Bref Symfony Messenger failure strategies 0.5.1(1y ago)11170.3k↓31.9%2[2 PRs](https://github.com/Happyr/bref-messenger-failure-strategies/pulls)MITPHPPHP >=7.3CI passing Since Jan 19Pushed 1mo ago1 watchersCompare [ Source](https://github.com/Happyr/bref-messenger-failure-strategies)[ Packagist](https://packagist.org/packages/happyr/bref-messenger-failure-strategies)[ GitHub Sponsors](https://github.com/Nyholm)[ RSS](/packages/happyr-bref-messenger-failure-strategies/feed)WikiDiscussions master Synced 2d ago READMEChangelog (10)Dependencies (6)Versions (13)Used By (0) Bref Messenger failure strategies ================================= [](#bref-messenger-failure-strategies) So you have fallen in love with [Bref](https://bref.sh) and you really want to use Symfony's excellent Messenger component. You've probably also installed the [Bref Symfony Messenger bundle](https://github.com/brefphp/symfony-messenger)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 ------- [](#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 ------- [](#example) On each consumer you can choose to let Symfony handle failures as described in [the documentation](https://symfony.com/doc/current/messenger.html#retries-failures). ``` # 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 ``` ### Health Score 45 — FairBetter than 91% of packages Maintenance67 Regular maintenance activity Popularity39 Limited adoption so far Community11 Small or concentrated contributor base Maturity49 Maturing project, gaining track record Bus Factor1 Top contributor holds 76.5% of commits — single point of failure How is this calculated?**Maintenance (25%)** — Last commit recency, latest release date, and issue-to-star ratio. Uses a 2-year decay window. **Popularity (30%)** — Total and monthly downloads, GitHub stars, and forks. Logarithmic scaling prevents top-heavy scores. **Community (15%)** — Contributors, dependents, forks, watchers, and maintainers. Measures real ecosystem engagement. **Maturity (30%)** — Project age, version count, PHP version support, and release stability. ### Release Activity Cadence Every ~177 days Recently: every ~357 days Total 11 Last Release 588d ago ### Community Maintainers ![](https://www.gravatar.com/avatar/401ccc5eea13c60cf807ae982af00e368e2166e2f26d8eb541dcd881a57385bc?d=identicon)[Nyholm](/maintainers/Nyholm) --- Top Contributors [![Nyholm](https://avatars.githubusercontent.com/u/1275206?v=4)](https://github.com/Nyholm "Nyholm (13 commits)")[![starred-gijs](https://avatars.githubusercontent.com/u/42832118?v=4)](https://github.com/starred-gijs "starred-gijs (4 commits)") ### Code Quality TestsPHPUnit ### Embed Badge ![Health badge](/badges/happyr-bref-messenger-failure-strategies/health.svg) ``` [![Health](https://phpackages.com/badges/happyr-bref-messenger-failure-strategies/health.svg)](https://phpackages.com/packages/happyr-bref-messenger-failure-strategies) ``` ### Alternatives [symfony/doctrine-messenger Symfony Doctrine Messenger Bridge 53295.8M257](/packages/symfony-doctrine-messenger)[symfony/redis-messenger Symfony Redis extension Messenger Bridge 21748.9M58](/packages/symfony-redis-messenger)[symfony/amqp-messenger Symfony AMQP extension Messenger Bridge 29459.2M109](/packages/symfony-amqp-messenger)[symfony/amazon-sqs-messenger Symfony Amazon SQS extension Messenger Bridge 4614.0M22](/packages/symfony-amazon-sqs-messenger)[shopware/storefront Storefront for Shopware 684.6M236](/packages/shopware-storefront)[shopware/core Shopware platform is the core for all Shopware ecommerce products. 585.6M574](/packages/shopware-core) PHPackages © 2026 [Directory](/)[Categories](/categories)[Trending](/trending)[Changelog](/changelog)[Analyze](/analyze)