wakeonweb/message-bus-receiver

WakeOnWeb MessageBus 接收器

维护者

详细信息

github.com/WakeOnWeb/message-bus-receiver

主页

源代码

问题

安装数: 3,458

依赖项: 0

建议者: 0

安全性: 0

星标: 0

关注者: 2

分支: 0

开放问题: 0

0.6.0 2019-07-08 09:55 UTC

Requires

Suggests

MIT da9fcb003e042359756716134abd44133f52c118

message-bus

This package is auto-updated.

Last update: 2024-09-08 21:02:39 UTC

README

安装

composer.json

    "wakeonweb/message-bus-receiver": "^0.1"

如果你使用 Symfony，你可以加载以下包 WakeOnWeb\MessageBusReceiver\App\Bundle\WakeonwebMessageBusReceiverBundle。

使用方法

Amqp 输入

wakeonweb_message_bus_receiver:
    buses:
        my_event_bus:
            bus: my_event_bus
            inputs:
                amqp:
                    message_name: EventBusExternalMessage
                    move_to_error_queue_on_error: false
            message_factory:
                mapping:
                    user_created: App\Event\UserCreatedEvent
                    foo: @id_service

然后在你的 prooph 事件总线定义中

prooph_service_bus:
  event_buses:
    my_event_bus:
        message_factory: wow.message_bus_receiver.my_event_bus.message_factory

定义消息被触发时的总线。

控制器路由输入

wakeonweb_message_bus_receiver:
    buses:
        my_event_bus:
            bus: my_event_bus
            inputs:
                controller_route: ~
            message_factory:
                mapping:
                    user_created: App\Event\UserCreatedEvent
                    foo: @id_service

然后在你的路由中

my_incoming_events:
    path: /incoming/events
    defaults: { _controller: 'wakeonweb.message_bus_receiver.my_event_bus.route_input:indexAction' }
    methods: [POST]

/!\ 目前只支持 JSON 格式正文 /!\