README

使用 MongoDB 作为后端的 PHP 消息队列。

特性

通过 MongoDB 查询选择消息和/或计数
通过 MongoDB 在机器间分发
消息优先级
延迟消息
运行消息超时和重发
原子确认和发送
仅基于有效负载的简单索引创建

最简单的使用

use TraderInteractive\Mongo\Queue;

$queue = new Queue('mongodb://localhost', 'queues', 'queue');
$queue->send(new Message());
$messages = $queue->get([], ['runningResetDuration' => 60]);
foreach ($messages as $message) {
    // Do something with message

    $queue->ack($message);
}

Composer

要作为本地、项目级别的依赖项添加库，请使用 Composer！只需将 traderinteractive/mongo-queue 添加到项目的 composer.json 文件中，例如

composer require traderinteractive/mongo-queue

文档

在源代码中找到，请查看！

联系方式

开发者可通过以下方式联系

贡献

如果您想贡献，请使用我们的构建过程对任何更改进行操作，构建通过后，在 github 上向我们发送拉取请求！

./vendor/bin/phpunit
./vendor/bin/phpcs

还有一个基于 docker 的 fig 配置，它将在 docker 容器内执行构建。这是构建应用程序的一种简单方法

fig run build

traderinteractive / mongo-queue

维护者

详细信息

README

特性

最简单的使用

Composer

文档

联系方式

贡献