README

消息总线

安装

$ composer require bauhaus/message-bus

入门

<?php

use Bauhaus\MessageBus;
use Bauhaus\MessageBusSettings;

class YourCommand {}
class YourCommandHandler
{
    public function __invoke(CommandA $command): void {}
}

class YourQuery {}
class YourQueryResult {}
class YourQueryHandler
{
    public function __invoke(YourQuery $query): YourQueryResult
    {
        return new YourQueryResult();
    }
}

$messageBus = MessageBus::build(
    MessageBusSettings::new()
        ->withPsrContainer(/* Pass here your favorite PSR container */)
        ->withHandlers(
            YourCommandAHandler::class,
            YourQueryHandler::class,
        );
);

$result = $messageBus->dispatch(new YourCommand());
is_null($result); // true

$result = $messageBus->dispatch(new YourCommand());
$result instanceof YourQueryResult; // true

贡献

提出问题： https://github.com/bauhausphp/message-bus/issues 代码： https://github.com/bauhausphp/contributor-tool

bauhaus / message-bus

维护者

详细信息

README

消息总线

安装

入门

贡献