for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
declare(strict_types=1);
namespace EventSauce\EventSourcing;
use RuntimeException;
final class Message
{
/**
* @var object
*/
private $event;
* @var array
private $headers;
public function __construct(object $event, array $headers = [])
$this->event = $event;
$this->headers = $headers;
}
public function withHeader(string $key, $value): Message
$clone = clone $this;
$clone->headers[$key] = $value;
return $clone;
public function withHeaders(array $headers): Message
$clone->headers = $headers + $clone->headers;
public function aggregateVersion(): int
$version = $this->headers[Header::AGGREGATE_ROOT_VERSION] ?? null;
if (null === $version) {
throw new RuntimeException("Can't get the version if the message has none.");
return (int) $version;
public function aggregateRootId(): ?AggregateRootId
return $this->headers[Header::AGGREGATE_ROOT_ID] ?? null;
public function timeOfRecording(): PointInTime
return PointInTime::fromString($this->headers[Header::TIME_OF_RECORDING]);
public function header(string $key)
return $this->headers[$key] ?? null;
public function headers(): array
return $this->headers;
public function event(): object
return $this->event;
EventSaucePHP /
EventSauce
