支持Enqueue

Enqueue 是一个 MIT 许可的开源项目，它的持续开发完全得益于社区和我们客户的支持。如果您想加入他们，请考虑：

消费扩展

您可以在快速指南中了解如何注册扩展。有专门的章节介绍如何在 Symfony 应用中添加扩展。

它将日志器设置为对消费者上下文进行队列。所有日志消息都将转向它。

它在处理消息后清除 Doctrine 的身份映射。它减少了内存使用。

它会测试数据库连接，如果连接丢失了它会重新连接。用于修复”MySQL has gone away”错误。

如果实体管理器已关闭，则该扩展会中断消费。

它重置所有带有“kernel.reset”标签的服务。例如，这包括所有的 Monolog 日志器（如果已安装），并将刷新/清理所有缓冲区，重置内部状态，并将它们恢复到可以再次接收日志记录的状态。

它带有 RPC 代码并简化了答复逻辑。它负责向答复队列发送答复消息。

它负责在代理端配置所有内容。队列、主题、绑定等。启用 --setup-broker 选项后，扩展将在运行时中添加。

该扩展对处理的消息进行计数，一旦达到限制，它就会中断消费。启用 --message-limit=10 选项后，该扩展在运行时中添加。

一旦达到内存限制，该扩展就会中断消费。启用 --memory-limit=512 选项后，该扩展在运行时中添加。该值为 Mb级别。

一旦达到时间限制，该扩展会中断消费。启用 --time-limit="now + 2 minutes" 选项后，该扩展在运行时中添加。

该扩展会捕获进程信号并优雅地停止消费。仅适用于 NIX 平台。

该扩展检查接收到的消息是否已重新投递（曾尝试处理该消息但失败）状态。如果是这样，该扩展会拒绝原始消息，并创建一个带有延迟的复制消息。

Enqueue QueueConsumer 有一个 ConsumerMonitoringExtension 扩展。它可以为你收集已消费消息和消费者统计信息，并将它们发送到 Grafana、InfluxDB 或 Datadog。