README

EventBus is a publish/subscribe event bus library.

The library gives the possibility to use multiple events buses at once, to do that use EventBusManager. Then you can register separately Domain EventBus and Integration EventBus.

• Required dependency injection container!

Drivers:

• Direct - Instant resolve and dispatch event on handlers.
• RabbitMQ - Publish events on queue and execute them separately using consumers.

Example of RabbitMq driver config:

$config = [
    'host' => INTEGRATION_EVENTBUS_AMQP_HOST,
    'port' => INTEGRATION_EVENTBUS_AMQP_PORT,
    'user' => INTEGRATION_EVENTBUS_AMQP_USER,
    'password' => INTEGRATION_EVENTBUS_AMQP_PASSWORD,
    'vhost' => INTEGRATION_EVENTBUS_AMQP_VHOST,
    'options' => [],

    'consumer' => [
        'queue' => INTEGRATION_EVENTBUS_AMQP_CONSUMER_QUEUE,
        'enable_heartbeat_sender' => false,
        'prefetch_count' => 3,
        'max_retries' => 3 // Default 3,
        'parking_lot_queue_name' => null // When max retries are exceeded and parking_lot is not set up, the message will be dropped.
    ],

    'publisher' => [
        'project' => INTEGRATION_EVENTBUS_PROJECT_NAME,
        'exchange' => INTEGRATION_EVENTBUS_AMQP_PUBLISHER_EXCHANGE,
        'routing_key_prefix' => INTEGRATION_EVENTBUS_AMQP_PUBLISHER_ROUTING_KEY_PREFIX,
    ],
];