wildpascal/remote-event-dispatcher

RemoteEventDispatcher for communicating between multiple systems.

Remote Event Dispatcher

, _(*1)

RemoteEventDispatcher for communicating between multiple systems., _(*2)

Installation

Require the bundle and its dependencies with composer:, _(*3)

$ composer require wildpascal/remote-event-dispatcher

Handler

Transport for Events. Possible Handlers: - AmqpHandler (Handler to send Events via a queue which is implementing the Amqp protocol), _(*4)

Dispatch Events

To dispatch events you have to configure the RemoteEventDispatcher. The RemoteEventDispatcher requires a Handler., _(*5)

You can dispatch every event which extends the AbstractEvent., _(*6)

// Configuration for RabbitMQ or any other queue which is based on AMQP protocol
$queueName = 'remote_event_dispatcher';
$config = [
    'host' => 'localhost',
];
$connection = new \PhpAmqpLib\Connection\AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->channel();

// Configure AmqpHandler
$handler = new \WP\RemoteEventDispatcher\Handler\Amqp\AmqpHandler($channel, $queueName);

// Setup RemoteEventDispatcher with AmqpHandler
$remoteEventDispatcher = new \WP\RemoteEventDispatcher\EventDispatcher\RemoteEventDispatcher($handler);

$printHalloEvent = new \WP\RemoteEventDispatcher\Model\MutableEvent('printHalloEvent');
$printTestEvent = new \WP\RemoteEventDispatcher\Model\MutableEvent('printTestEvent');

$remoteEventDispatcher->dispatch($printHalloEvent);
$remoteEventDispatcher->dispatch($printTestEvent);

Listen for Events

To Listen for Events you have to configure the RemoteEventListener. The RemoteEventListener requires a Handler and a EventStrategy., _(*7)

You also can use a EventStrategyRegistry to register different EventStrategies based on the eventName to implement a logic based on Events, _(*8)

// Configuration for RabbitMQ or any other queue which is based on AMQP protocol
$queueName = 'remote_event_dispatcher';
$config = [
    'host' => 'localhost',
];
$connection = new \PhpAmqpLib\Connection\AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->channel();

// Configure AmqpHandler
$handler = new \WP\RemoteEventDispatcher\Handler\Amqp\AmqpHandler($channel, $queueName);

// Setup your custom EventStrategy
$eventStrategy = new YourCustomEventStrategy();

// Setup RemoteEventListener with AmqpHandler
$remoteEventListener = new \WP\RemoteEventDispatcher\EventListener\RemoteEventListener($handler, $eventStrategy);
$remoteEventListener->listen();

License

This bundle is under the MIT license. See the complete license in the bundle:, _(*9)

Resources/meta/LICENSE