n3ttech/messeging

CQRS + ES for php

1.3.5 2019-12-06 05:17 UTC

Requires

• php: >=7.3
• ext-json: *
• n3ttech/valuing: ^1.1
• psr/container: ^1.0
• ramsey/uuid: ^3.8

Requires (Dev)

• friendsofphp/php-cs-fixer: ^2.15
• n3ttech/checking: ^1.1
• phpstan/phpstan: ^0.11.19
• phpunit/phpunit: ^8.4
• squizlabs/php_codesniffer: ^3.5

MIT

• n3ttech

• messaging
• command bus
• event bus
• Query Bus

README

#Library for handling CQRS and ES

1. Define event bus

use N3tt3ch\Messaging\Event;

$eventRouterFactory = new Event\EventRouting\EventRouterFactory();
$eventTransporterFactory = new Event\EventTransporting\EventTransporterFactory(
	$eventRouterFactory->fromDirectory('path to directory with event map'),
	new Event\EventSourcing\EventProjectionProvider($container)
);

$eventBus = new Event\EventBus($eventTransporterFactory->createDefault());

Further we need to create event storage and event stream

use N3tt3ch\Messaging\Event;
use N3tt3ch\Messaging\Snapshot;

$snapshotStorage = new Snapshot\SnapshotStore\SnapshotStorage($container->get(Snapshot\Persist\SnapshotRepository::class));
$eventStorageFactory = new Event\EventStore\EventStorageFactory($container->get(Event\Persist\EventStreamRepository::class));
$eventStorage = $eventStorageFactory->create($eventBus);

$someAggregateRepository = new SomeAggregateRepository($eventStorage, $snapshotStorage);

1. Define command bus

use N3tt3ch\Messaging\Command;

$commandHandlerProvider = new Command\CommandHandling\CommandHandlerProvider($container);
$commandRouterFactory = new Command\CommandRouting\CommandRouterFactory($commandHandlerProvider);
$commandTransporterFactory = new Command\CommandTransporting\CommandTransporterFactory($commandRouterFactory->createDefault());

$commandBus = new Command\CommandBus($commandTransporterFactory->createDefault());

1. Define query bus

use N3tt3ch\Messaging\Query;

$queryHandlerProvider = new Query\QueryHandling\QueryHandlerProvider($container);
$queryRouterFactory = new Query\QueryRouting\QueryRouterFactory($queryHandlerProvider);
$queryTransporterFactory = new Query\QueryTransporting\QueryTransporterFactory($queryRouterFactory->createDefault());

$queryBus = new Query\QueryBus($queryTransporterFactory->createDefault());

You can use your own message transports. You can use your own message naming strategies.

Please view transport and routing factories.