README

Queue-interop 异步事件总线

Queue-interop 异步装饰器用于事件总线

安装

Composer

composer require phpgears/event-async-queue-interop

用法

需要 composer 自动加载文件

require './vendor/autoload.php';

异步事件总线

有关异步事件总线的更多信息，请参阅 phpgears/event-async

use Gears\Event\Async\AsyncEventBus;
use Gears\Event\Async\QueueInterop\QueueInteropEventQueue;
use Gears\Event\Async\Serializer\JsonEventSerializer;
use Gears\Event\Async\Discriminator\ParameterEventDiscriminator;

/* @var \Gears\Event\EventBus $eventBus */
/* @var \Interop\Queue\PsrContext $context */
/* @var \Interop\Queue\PsrDestination $destination */

$eventQueue = new QueueInteropEventQueue(new JsonEventSerializer(), $context, $destination);

$asyncEventBus = new AsyncEventBus(
    $eventBus,
    $eventQueue,
    new ParameterEventDiscriminator('async')
);

$asyncEvent = CustomEvent::occurred(['async' => true]);

$asyncEventBus->dispatch($asyncEvent);

一些 Queue-interop 实现可用，例如 Enqueue，它支持大量消息队列

贡献

发现了一个错误或有一个功能请求？请创建一个新问题。在创建问题之前请查看现有问题。

请参阅 CONTRIBUTING.md 文件

许可

请参阅源代码中包含的 LICENSE 文件，以获取许可证条款副本。

phpgears / event-async-queue-interop

维护者

详细信息

README

Queue-interop 异步事件总线

安装

Composer

用法

异步事件总线

贡献

许可