The message repository will store the event messages where and how you want them to be stored. This is usually a database but could be anywhere. The uses the Message Repository to save the event messages that were raised.
Usage
<?php
use SonsOfPHP\Component\EventSourcing\Message\Repository\MessageRepositoryInterface;
use SonsOfPHP\Component\EventSourcing\Message\MessageInterface;
use SonsOfPHP\Component\EventSourcing\Aggregate\AggregateIdInterface;
use SonsOfPHP\Component\EventSourcing\Aggregate\AggregateVersionInterface;
// @var MessageRepositoryInterface $messageRepository
// @var MessageInterface $message
$messageRepository->persist($message);
// @var AggregateIdInterface|string $aggregateId
// @var MessageInterface[] $eventMessages
$eventMessages = $messageRepository->find($aggregateId);
// or to grab event messages after a specific version
// @var AggregateVersionInterface|int $aggregateVersion
$eventMessages = $messageRepository->find($aggregateId, $aggregateVersion);
InMemoryMessageRepository
This repository is mainly used for testing, however to keep the examples easy we will start with this message repository.
<?php
use SonsOfPHP\Component\EventSourcing\Message\Repository\InMemoryRepository;
$messageRepository = new InMemoryRepository();
DoctrineDbalMessageRepository
!!! attention The DoctrineDbalMessageRepository requires the sonsofphp/event-sourcing-doctrine package.
The DoctrineDbalMessageRepository allows you to persist event messages in the database.
<?php
use SonsOfPHP\Bridge\Doctrine\EventSourcing\DoctrineDbalMessageRepository;
use SonsOfPHP\Bridge\Doctrine\EventSourcing\TableSchemaInterface;
use Doctrine\DBAL\Connection;
use SonsOfPHP\Component\EventSourcing\Message\Serializer\MessageSerializerInterface;
$messageRepository = new DoctrineDbalMessageRepository(
$connection, // @var Connection
$messageSerializer, // @var MessageSerializerInterface
$tableSchema // @var TableSchemaInterface
);
The TableSchemaInterface defines what table to use along with the columns and mapping information. They are easy to work with and create custom schemas.
