answear/messenger-heartbeat-bundle

Symfony messenger AMQP Transport with PNCTL Heartbeat

1.1.0 2024-08-30 09:54 UTC

This package is auto-updated.

Last update: 2024-08-30 09:55:52 UTC


README

安装

  • 使用Composer安装
composer require answear/messenger-heartbeat-bundle

Answear\MessengerHeartbeatBundle\AnswearMessengerHeartbeatBundle::class => ['all' => true],
应该由Symfony Flex自动添加到您的 config/bundles.php 文件中。

设置

将中间件作为最后一个元素添加,以防止当RabbitMQ服务器关闭带有PRECONDITION_FAILED的通道时重复消息 https://rabbitmq.cn/consumers.html#acknowledgement-timeout

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

总结

欢迎提交带有新功能、改进或错误修复的pull请求。Answear团队将非常感谢任何评论。