webit/message-bus

1.0.0 2018-01-05 06:14 UTC

This package is auto-updated.

Last update: 2024-09-20 22:43:19 UTC


README

该库提供了一个抽象层,用于向/从消息总线发布/消费消息。

安装

composer require webit/message-bus ^1.0.0

概念介绍

消息

消息是用于由发布者发布并由消费者消费的简单容器。

$message = new Message('message-type', json_encode(['some' => 'data to be sent']));

消息 类型是必需的,用于识别发送的消息类型,并有助于了解如何处理。消息 内容是消息本身。它可以是任何字符串(不一定是json)。

发布者和消费者

发布者通过底层基础设施发布消息,但消费者等待消息进行处理。

基础设施将由一个单独的包提供。它应该提供 "webit/message-bus-infrastructure:^1.0.0" Composer 虚拟包。

测试

./vendor/bin/phpunit