zelenin/message-bus

Lightweight message bus

Message bus

Installation

Composer

The preferred way to install this extension is through Composer., _(*1)

Either run, _(*2)

php composer.phar require zelenin/message-bus "~0.0.1"

or add, _(*3)

"zelenin/message-bus": "~0.0.1"

to the require section of your composer.json, _(*4)

Usage

Example

$handlers = [
    CreatePost::class => new CreatePostHandler($postRepository)
];

$middlewares = [
    new HandlerMiddleware(new MemoryLocator($handlers))
];

$commandBus = new MiddlewareBus(new MiddlewareStack($middlewares));

$message = new CreatePost('Post title', 'Post content');

$context = $commandBus->handle($message);

ProviderLocator:, _(*5)

$provider = new AnnotationProvider(__DIR__ . '/src');
if ($isProduction) {
    $provider = new CacheProvider(__DIR__ . '/data/handlers-cache.php', $provider);
}
$locator = new ProviderLocator($provider, new ContainerHandlerResolver($container));

return new MiddlewareBus(new MiddlewareStack([
    new HandlerMiddleware($locator),
]));

ContainerHandlerResolver may be used for PSR-11 Container support., _(*6)

Context

The Message bus uses the immutable Context to transfer data through middlewares and return it to consumer., _(*7)

Author

Aleksandr Zelenin, e-mail: aleksandr@zelenin.me, _(*8)