wakeonweb/message-bus-publisher

WakeOnWeb MessageBus 发布者

维护者

详细信息

github.com/WakeOnWeb/message-bus-publisher

主页

源代码

问题

安装数: 4,616

依赖项: 0

建议者: 0

安全性: 0

星标: 1

关注者: 2

分支: 1

开放问题: 4

v0.3.1 2018-07-10 14:24 UTC

Requires

Suggests

private fc2c83c992077728db40aaf85e493cfbeb27a1dd

message-bus

This package is auto-updated.

Last update: 2024-09-08 07:07:14 UTC

README

重要，我们不会保证0.x标签的BC兼容性，只会从1.x开始保证

安装

composer.json

    "require": [
        "wakeonweb/message-bus-publisher": "^0.1"
    ],

如果你使用 Symfony，你可以加载这个包 WakeOnWeb\MessageBusPublisher\App\Bundle\WakeonwebMessageBusPublisherBundle.

使用

同步

wakeonweb_message_bus_publisher:
    publishing:
        listened_prooph_buses: [event_bus]
        delivery_mode: synchronous
    driver:
        # ... see driver chapter

定义此发布者将监听的 prooph buses。一旦在这些 buses 中派发了消息，它将派发消息到目标。

异步

wakeonweb_message_bus_publisher:
    publishing:
        listened_prooph_buses: [event_bus]
        delivery_mode: asynchronous
        queue_name: my_queue_name.{target}
    driver:
        # ... see driver chapter

定义此发布者将监听的 prooph buses。一旦在这些 buses 中派发了消息，它将猜测路由然后在名为 my_queue_name.{target} 的专用队列中派发此消息，其中 {target} 是目标名称。

然后消费这些消息并将它们派发到目标

./bin/console bernard:consume my_queue_name.target_x

审计

此库可以审计监听的消息和目标消息

wakeonweb_message_bus_publisher:
    audit:
        drivers:
            monolog:
                level: notice
                only_routed_messages: true # do you want to log each messages ?
            doctrine_orm: ~
            services:
                - x
                - y

你可以有任意多的驱动程序。

要进一步配置，请参阅以下文档。

Flow

flow

已实现的驱动程序

其他文档