answear/messenger-heartbeat-bundle

Symfony messenger AMQP Transport with PNCTL Heartbeat

2.0.0 2024-10-02 12:30 UTC

Requires

• php: ^8.2
• ext-amqp: *
• symfony/amqp-messenger: ^6.0|^7.0
• symfony/http-kernel: ^6.0|^7.0
• symfony/messenger: ^6.0|^7.0

Requires (Dev)

• friendsofphp/php-cs-fixer: ^3.63
• phpro/grumphp: ^2.6
• phpstan/phpstan: ^1.11
• phpstan/phpstan-webmozart-assert: ^1.2
• phpunit/phpunit: ^10.5
• roave/security-advisories: dev-master
• symfony/phpunit-bridge: 7.1.*

MIT

README

Installation

• install with Composer

composer require answear/messenger-heartbeat-bundle

Answear\MessengerHeartbeatBundle\AnswearMessengerHeartbeatBundle::class => ['all' => true],
should be added automatically to your config/bundles.php file by Symfony Flex.

Setup

Add middleware as the last element to prevent duplicate messages when RabbitMQ server closes a channel with PRECONDITION_FAILED https://www.rabbitmq.com/consumers.html#acknowledgement-timeout

# config/packages/messenger.yaml
framework:
    messenger:
        default_bus: messenger.bus.default
        buses:
            messenger.bus.default:
                middleware:
                    ...
                    - 'Answear\MessengerHeartbeatBundle\Middleware\TransportExceptionsMiddleware'
                    

Final notes

Feel free to open pull requests with new features, improvements or bug fixes. The Answear team will be grateful for any comments.