answear/messenger-heartbeat-bundle

Symfony messenger AMQP Transport with PNCTL Heartbeat

1.0.3 2024-04-02 11:48 UTC

Requires

• php: ~8.1
• ext-amqp: *
• symfony/amqp-messenger: ^6.0
• symfony/http-kernel: ^5.4|^6.0
• symfony/messenger: ^6.0

Requires (Dev)

• friendsofphp/php-cs-fixer: ^3.4
• phpro/grumphp: ^1.5.0
• phpstan/phpstan: ^1.4
• phpstan/phpstan-webmozart-assert: ^1.0
• phpunit/phpunit: ^9.5.28
• roave/security-advisories: dev-master
• symfony/phpunit-bridge: 6.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.