WakeOnWeb MessageBusPublisher

important, we don't ensure BC compatibility in 0.x tags, we'll ensure it from 1.x only, _(*1)

Installation

composer.json, _(*2)

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

If you use Symfony, you can load the bundle WakeOnWeb\MessageBusPublisher\App\Bundle\WakeonwebMessageBusPublisherBundle., _(*3)

Usage

Synchronous

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

Define the prooph buses this publisher will listen to. Once an message is dispatched in theses buses, it'll dispatch messages to targets., _(*4)

Asynchronous

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

Define the prooph buses this publisher will listen to. Once an message is dispatched in theses buses, it'll guess route then dispatch this message in a dedicated queue called my_queue_name.{target} where {target} is the target name., _(*5)

Then consume theses messages to dispatch them to targets:, _(*6)

./bin/console bernard:consume my_queue_name.target_x

Audit

This library can audit listened messages and targeted messages:, _(*7)

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

You can have as many drivers as you want., _(*8)

To go further in configuration, look at documentation below., _(*9)

Flow

flow , _(*10)

library message-bus-publisher