README

安装

要通过 Composer 安装，请使用以下命令，它将自动检测最新版本并将其绑定到 ^。

composer require wyrihaximus/react-observable-bunny

使用方法

以下示例将连接到 RabbitMQ，从 queue:name 队列中消费消息，在取消订阅和断开客户端之前，设置预取（QOS）为 10，持续两分钟。

<?php

use Bunny\Async\Client;
use React\EventLoop\Factory;
use WyriHaximus\React\ObservableBunny\Message;
use WyriHaximus\React\ObservableBunny\ObservableBunny;

$loop = Factory::create();
$bunny = new Client($loop);
$observableBunny = new ObservableBunny($loop, $bunny);
// OR to check the dispose status on another interval then once a second, like twice a second
$observableBunny = new ObservableBunny($loop, $bunny, 0.5);
$queue = $observableBunny->consume('queue:name', [0, 10]);
$loop->addTimer(120, function () use ($queue, $bunny) {
    $queue->dispose();
    $bunny->disconnect();
});
$queue->subscribe(function (Message $message) {
    // Handle message
});

$loop->run();

许可证

MIT 许可证 (MIT)

特此授予任何获得此软件及其相关文档文件（以下简称“软件”）副本的任何人，免费使用该软件的权利，不受任何限制，包括但不限于使用、复制、修改、合并、发布、分发、再许可和/或销售软件副本的权利，以及准许向软件提供方提供软件的人使用该软件的权利，但受以下条件的约束

软件按“现状”提供，不提供任何明示或暗示的保证，包括但不限于适销性、特定用途的适用性和非侵权性保证。在任何情况下，作者或版权持有人不对任何索赔、损害或其他责任负责，无论该责任是基于合同、侵权或其他法律，无论该责任源于、因之而起或与此软件或其使用或其他交易有关。

hansel23 / observable-bunny

维护者

详细信息

README

安装

使用方法

许可证