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)

特此授予任何人免费获得本软件及其相关文档文件（“软件”）副本的权利，以无限制地处理软件，包括但不限于使用、复制、修改、合并、发布、分发、再许可和/或出售软件副本，并允许向软件提供者提供软件的人员这样做，但受以下条件的约束

wyrihaximus / react-observable-bunny

维护者

详情

README

安装

用法

许可协议