diff --git a/src/ContinuousPipe/Events/Aggregate.php b/src/ContinuousPipe/Events/Aggregate.php
new file mode 100644
index 0000000..9ad80fd
--- /dev/null
+++ b/src/ContinuousPipe/Events/Aggregate.php
@@ -0,0 +1,8 @@
+<?php
+
+namespace ContinuousPipe\Events;
+
+interface Aggregate
+{
+    public function raisedEvents() : array;
+}
diff --git a/src/ContinuousPipe/Events/AggregateNotFound.php b/src/ContinuousPipe/Events/AggregateNotFound.php
new file mode 100644
index 0000000..2805542
--- /dev/null
+++ b/src/ContinuousPipe/Events/AggregateNotFound.php
@@ -0,0 +1,7 @@
+<?php
+
+namespace ContinuousPipe\Events;
+
+class AggregateNotFound extends \Exception
+{
+}
diff --git a/src/ContinuousPipe/Events/AggregateRepository.php b/src/ContinuousPipe/Events/AggregateRepository.php
new file mode 100644
index 0000000..d7aaf28
--- /dev/null
+++ b/src/ContinuousPipe/Events/AggregateRepository.php
@@ -0,0 +1,15 @@
+<?php
+
+namespace ContinuousPipe\Events;
+
+interface AggregateRepository
+{
+    /**
+     * @param string $aggregateIdentifier
+     *
+     * @throws AggregateNotFound
+     *
+     * @return Aggregate
+     */
+    public function find(string $aggregateIdentifier) : Aggregate;
+}
diff --git a/src/ContinuousPipe/Events/Capabilities/ApplyEventCapability.php b/src/ContinuousPipe/Events/Capabilities/ApplyEventCapability.php
new file mode 100644
index 0000000..abfbbc0
--- /dev/null
+++ b/src/ContinuousPipe/Events/Capabilities/ApplyEventCapability.php
@@ -0,0 +1,33 @@
+<?php
+
+namespace ContinuousPipe\Events\Capabilities;
+
+trait ApplyEventCapability
+{
+    public static function fromEvents(array $events)
+    {
+        $self = new static();
+
+        foreach ($events as $event) {
+            $self->apply($event);
+        }
+
+        return $self;
+    }
+
+    public function apply($event)
+    {
+        $className = get_class($event);
+        $classNameTail = substr($className, strrpos($className, '\\') + 1);
+
+        $method = sprintf('apply%s', ucfirst($classNameTail));
+        if (!method_exists($this, $method)) {
+            throw new \BadMethodCallException(
+                "There is no event named '$method' that can be applied to '".get_class($this)."'. ".
+                'If you just want to emit an event without applying changes use the raise() method.'
+            );
+        }
+
+        $this->$method($event);
+    }
+}
diff --git a/src/ContinuousPipe/Events/Capabilities/RaiseEventCapability.php b/src/ContinuousPipe/Events/Capabilities/RaiseEventCapability.php
new file mode 100644
index 0000000..5a5973b
--- /dev/null
+++ b/src/ContinuousPipe/Events/Capabilities/RaiseEventCapability.php
@@ -0,0 +1,23 @@
+<?php
+
+namespace ContinuousPipe\Events\Capabilities;
+
+trait RaiseEventCapability
+{
+    private $raisedEvents = [];
+
+    protected function raise($event)
+    {
+        $this->raisedEvents[] = $event;
+    }
+
+    public function raisedEvents() : array
+    {
+        return $this->raisedEvents;
+    }
+
+    public function eraseEvents()
+    {
+        $this->raisedEvents = [];
+    }
+}
diff --git a/src/ContinuousPipe/Events/EventStore/Doctrine/DoctrineEventStore.php b/src/ContinuousPipe/Events/EventStore/Doctrine/DoctrineEventStore.php
new file mode 100644
index 0000000..23ed3c1
--- /dev/null
+++ b/src/ContinuousPipe/Events/EventStore/Doctrine/DoctrineEventStore.php
@@ -0,0 +1,83 @@
+<?php
+
+namespace ContinuousPipe\Events\EventStore\Doctrine;
+
+use ContinuousPipe\Events\EventStore\EventStore;
+use ContinuousPipe\Events\EventStore\EventStoreException;
+use ContinuousPipe\Events\TimeResolver\TimeResolver;
+use Doctrine\ORM\EntityManager;
+use Doctrine\ORM\ORMException;
+use JMS\Serializer\SerializerInterface;
+use Ramsey\Uuid\Uuid;
+
+class DoctrineEventStore implements EventStore
+{
+    /**
+     * @var EntityManager
+     */
+    private $entityManager;
+    /**
+     * @var SerializerInterface
+     */
+    private $serializer;
+    /**
+     * @var TimeResolver
+     */
+    private $timeResolver;
+
+    /**
+     * @param EntityManager $entityManager
+     * @param SerializerInterface $serializer
+     * @param TimeResolver $timeResolver
+     */
+    public function __construct(
+        EntityManager $entityManager,
+        SerializerInterface $serializer,
+        TimeResolver $timeResolver
+    ) {
+        $this->entityManager = $entityManager;
+        $this->serializer = $serializer;
+        $this->timeResolver = $timeResolver;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function store(string $stream, $event)
+    {
+        $dataTransferObject = new EventDto(
+            Uuid::uuid4(),
+            $stream,
+            get_class($event),
+            $this->serializer->serialize($event, 'json'),
+            $this->timeResolver->resolve()
+        );
+
+        try {
+            $this->entityManager->persist($dataTransferObject);
+            $this->entityManager->flush($dataTransferObject);
+        } catch (ORMException $e) {
+            throw new EventStoreException('Unable to store the event', $e->getCode(), $e);
+        }
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function read(string $stream): array
+    {
+        $dataTransferObjects = $this->entityManager->getRepository(EventDto::class)->findBy([
+            'stream' => $stream,
+        ], [
+            'creationDate' => 'ASC'
+        ]);
+
+        return array_map(function (EventDto $dataTransferObject) {
+            return $this->serializer->deserialize(
+                $dataTransferObject->getJsonSerialized(),
+                $dataTransferObject->getClass(),
+                'json'
+            );
+        }, $dataTransferObjects);
+    }
+}
diff --git a/src/ContinuousPipe/Events/EventStore/Doctrine/EventDto.php b/src/ContinuousPipe/Events/EventStore/Doctrine/EventDto.php
new file mode 100644
index 0000000..009db03
--- /dev/null
+++ b/src/ContinuousPipe/Events/EventStore/Doctrine/EventDto.php
@@ -0,0 +1,100 @@
+<?php
+
+namespace ContinuousPipe\Events\EventStore\Doctrine;
+
+use Doctrine\ORM\Mapping as ORM;
+use Ramsey\Uuid\UuidInterface;
+
+/**
+ * @ORM\Entity
+ * @ORM\Table(indexes={
+ *     @ORM\Index(name="idx_event_dto_by_stream", columns={"stream"}),
+ * })
+ */
+class EventDto
+{
+    /**
+     * @ORM\Id
+     * @ORM\Column(type="uuid")
+     *
+     * @var UuidInterface
+     */
+    private $uuid;
+
+    /**
+     * @ORM\Column(type="string", nullable=false)
+     *
+     * @var string
+     */
+    private $stream;
+
+    /**
+     * @ORM\Column(type="string", nullable=false)
+     *
+     * @var string
+     */
+    private $class;
+
+    /**
+     * @ORM\Column(type="text", nullable=false)
+     *
+     * @var string
+     */
+    private $jsonSerialized;
+
+    /**
+     * @ORM\Column(type="datetime", nullable=false)
+     *
+     * @var \DateTimeInterface
+     */
+    private $creationDate;
+
+    public function __construct(UuidInterface $uuid, string $stream, string $class, string $jsonSerialized, \DateTimeInterface $creationDate)
+    {
+        $this->uuid = $uuid;
+        $this->stream = $stream;
+        $this->class = $class;
+        $this->jsonSerialized = $jsonSerialized;
+        $this->creationDate = $creationDate;
+    }
+
+    /**
+     * @return UuidInterface
+     */
+    public function getUuid(): UuidInterface
+    {
+        return $this->uuid;
+    }
+
+    /**
+     * @return string
+     */
+    public function getStream(): string
+    {
+        return $this->stream;
+    }
+
+    /**
+     * @return string
+     */
+    public function getClass(): string
+    {
+        return $this->class;
+    }
+
+    /**
+     * @return string
+     */
+    public function getJsonSerialized(): string
+    {
+        return $this->jsonSerialized;
+    }
+
+    /**
+     * @return \DateTimeInterface
+     */
+    public function getCreationDate(): \DateTimeInterface
+    {
+        return $this->creationDate;
+    }
+}
diff --git a/src/ContinuousPipe/Events/EventStore/EventStore.php b/src/ContinuousPipe/Events/EventStore/EventStore.php
new file mode 100644
index 0000000..2febebd
--- /dev/null
+++ b/src/ContinuousPipe/Events/EventStore/EventStore.php
@@ -0,0 +1,27 @@
+<?php
+
+namespace ContinuousPipe\Events\EventStore;
+
+interface EventStore
+{
+    /**
+     * Write an event to the given stream.
+     *
+     * @param string $stream
+     * @param mixed $event
+     *
+     * @throws EventStoreException
+     */
+    public function store(string $stream, $event);
+
+    /**
+     * Read all the events from the given stream.
+     *
+     * @param string $stream
+     *
+     * @throws EventStoreException
+     *
+     * @return mixed[]
+     */
+    public function read(string $stream) : array;
+}
diff --git a/src/ContinuousPipe/Events/EventStore/EventStoreException.php b/src/ContinuousPipe/Events/EventStore/EventStoreException.php
new file mode 100644
index 0000000..43804de
--- /dev/null
+++ b/src/ContinuousPipe/Events/EventStore/EventStoreException.php
@@ -0,0 +1,7 @@
+<?php
+
+namespace ContinuousPipe\Events\EventStore;
+
+class EventStoreException extends \Exception
+{
+}
diff --git a/src/ContinuousPipe/Events/EventStore/EventStreamResolver.php b/src/ContinuousPipe/Events/EventStore/EventStreamResolver.php
new file mode 100644
index 0000000..76d6914
--- /dev/null
+++ b/src/ContinuousPipe/Events/EventStore/EventStreamResolver.php
@@ -0,0 +1,13 @@
+<?php
+
+namespace ContinuousPipe\Events\EventStore;
+
+interface EventStreamResolver
+{
+    /**
+     * @param mixed $event
+     *
+     * @return string|null
+     */
+    public function streamByEvent($event);
+}
diff --git a/src/ContinuousPipe/Events/EventStore/GetEventStore/HttpEventStoreAdapter.php b/src/ContinuousPipe/Events/EventStore/GetEventStore/HttpEventStoreAdapter.php
new file mode 100644
index 0000000..2b373a7
--- /dev/null
+++ b/src/ContinuousPipe/Events/EventStore/GetEventStore/HttpEventStoreAdapter.php
@@ -0,0 +1,63 @@
+<?php
+
+namespace ContinuousPipe\Events\GetEventStore\EventStore;
+
+use ContinuousPipe\Events\EventStore\EventStore;
+use EventStore\EventStore as EventStoreClient;
+use EventStore\WritableEvent;
+use JMS\Serializer\SerializerInterface;
+
+class HttpEventStoreAdapter implements EventStore
+{
+    private $client;
+    private $serializer;
+    private $eventStoreHost;
+
+    public function __construct(SerializerInterface $serializer, string $eventStoreHost)
+    {
+        $this->serializer = $serializer;
+        $this->eventStoreHost = $eventStoreHost;
+    }
+
+    public function store(string $stream, $event)
+    {
+        $className = get_class($event);
+        $name = substr($className, strrpos($className, '\\') + 1);
+
+        $this->client()->writeToStream($stream, WritableEvent::newInstance(
+            $name,
+            \GuzzleHttp\json_decode($this->serializer->serialize($event, 'json'), true),
+            [
+                'class' => get_class($event),
+            ]
+        ));
+    }
+
+    public function read(string $stream) : array
+    {
+        $iterator = $this->client()->forwardStreamFeedIterator($stream);
+        $events = [];
+
+        foreach ($iterator as $entryWithEvent) {
+            /** @var \EventStore\StreamFeed\EntryWithEvent $entryWithEvent */
+            $event = $entryWithEvent->getEvent();
+
+            $events[] = $this->serializer->deserialize(
+                \GuzzleHttp\json_encode($event->getData()),
+                $event->getMetadata()['class'],
+                'json'
+            );
+        }
+
+        return $events;
+    }
+
+    private function client()
+    {
+        if (null === $this->client) {
+            $this->client = new EventStoreClient('http://'.$this->eventStoreHost.':2113');
+        }
+
+        return $this->client;
+    }
+}
diff --git a/src/ContinuousPipe/Events/EventStore/InMemoryEventStore.php b/src/ContinuousPipe/Events/EventStore/InMemoryEventStore.php
new file mode 100644
index 0000000..1a16b57
--- /dev/null
+++ b/src/ContinuousPipe/Events/EventStore/InMemoryEventStore.php
@@ -0,0 +1,26 @@
+<?php
+
+namespace ContinuousPipe\Events\EventStore;
+
+class InMemoryEventStore implements EventStore
+{
+    private $streams = [];
+
+    public function store(string $stream, $event)
+    {
+        if (!array_key_exists($stream, $this->streams)) {
+            $this->streams[$stream] = [];
+        }
+
+        $this->streams[$stream][] = $event;
+    }
+
+    public function read(string $stream): array
+    {
+        if (!array_key_exists($stream, $this->streams)) {
+            return [];
+        }
+
+        return $this->streams[$stream];
+    }
+}
diff --git a/src/ContinuousPipe/Events/EventStream/AbstractEventStream.php b/src/ContinuousPipe/Events/EventStream/AbstractEventStream.php
new file mode 100644
index 0000000..4b984f9
--- /dev/null
+++ b/src/ContinuousPipe/Events/EventStream/AbstractEventStream.php
@@ -0,0 +1,24 @@
+<?php
+
+namespace ContinuousPipe\Events\EventStream;
+
+abstract class AbstractEventStream
+{
+    /**
+     * @var string
+     */
+    private $name;
+
+    /**
+     * @param string $name
+     */
+    protected function __construct(string $name)
+    {
+        $this->name = $name;
+    }
+
+    public function __toString()
+    {
+        return $this->name;
+    }
+}
diff --git a/src/ContinuousPipe/Events/SimpleBus/StoreEventsMiddleware.php b/src/ContinuousPipe/Events/SimpleBus/StoreEventsMiddleware.php
new file mode 100644
index 0000000..271b600
--- /dev/null
+++ b/src/ContinuousPipe/Events/SimpleBus/StoreEventsMiddleware.php
@@ -0,0 +1,43 @@
+<?php
+
+namespace ContinuousPipe\Events\SimpleBus;
+
+use ContinuousPipe\Events\Event;
+use ContinuousPipe\Events\EventStore\EventStore;
+use ContinuousPipe\Events\EventStore\EventStreamResolver;
+use SimpleBus\Message\Bus\Middleware\MessageBusMiddleware;
+
+class StoreEventsMiddleware implements MessageBusMiddleware
+{
+    /**
+     * @var EventStore
+     */
+    private $eventStore;
+
+    /**
+     * @var EventStreamResolver
+     */
+    private $eventStreamResolver;
+
+    /**
+     * @param EventStore $eventStore
+     * @param EventStreamResolver $eventStreamResolver
+     */
+    public function __construct(EventStore $eventStore, EventStreamResolver $eventStreamResolver)
+    {
+        $this->eventStore = $eventStore;
+        $this->eventStreamResolver = $eventStreamResolver;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function handle($message, callable $next)
+    {
+        if (null !== ($stream = $this->eventStreamResolver->streamByEvent($message))) {
+            $this->eventStore->store($stream, $message);
+        }
+
+        $next($message);
+    }
+}
diff --git a/src/ContinuousPipe/Events/TimeResolver/NativeTimeResolver.php b/src/ContinuousPipe/Events/TimeResolver/NativeTimeResolver.php
new file mode 100644
index 0000000..409a4cc
--- /dev/null
+++ b/src/ContinuousPipe/Events/TimeResolver/NativeTimeResolver.php
@@ -0,0 +1,16 @@
+<?php
+
+namespace ContinuousPipe\Events\TimeResolver;
+
+class NativeTimeResolver implements TimeResolver
+{
+    /**
+     * {@inheritdoc}
+     */
+    public function resolve(): \DateTimeInterface
+    {
+        $microTime = sprintf('%01.4f', microtime(true));
+
+        return \DateTime::createFromFormat('U.u', $microTime);
+    }
+}
diff --git a/src/ContinuousPipe/Events/TimeResolver/TimeResolver.php b/src/ContinuousPipe/Events/TimeResolver/TimeResolver.php
new file mode 100644
index 0000000..347e43d
--- /dev/null
+++ b/src/ContinuousPipe/Events/TimeResolver/TimeResolver.php
@@ -0,0 +1,8 @@
+<?php
+
+namespace ContinuousPipe\Events\TimeResolver;
+
+interface TimeResolver
+{
+    public function resolve() : \DateTimeInterface;
+}
diff --git a/src/ContinuousPipe/Events/Transaction/PopAndDispatchEventsTransactionManager.php b/src/ContinuousPipe/Events/Transaction/PopAndDispatchEventsTransactionManager.php
new file mode 100644
index 0000000..ad94a13
--- /dev/null
+++ b/src/ContinuousPipe/Events/Transaction/PopAndDispatchEventsTransactionManager.php
@@ -0,0 +1,52 @@
+<?php
+
+namespace ContinuousPipe\Events\Transaction;
+
+use ContinuousPipe\Events\Aggregate;
+use ContinuousPipe\Events\AggregateRepository;
+use SimpleBus\Message\Bus\MessageBus;
+
+class PopAndDispatchEventsTransactionManager implements TransactionManager
+{
+    /**
+     * @var AggregateRepository
+     */
+    private $aggregateRepository;
+
+    /**
+     * @var MessageBus
+     */
+    private $eventBus;
+
+    /**
+     * @param AggregateRepository $aggregateRepository
+     * @param MessageBus $eventBus
+     */
+    public function __construct(AggregateRepository $aggregateRepository, MessageBus $eventBus)
+    {
+        $this->aggregateRepository = $aggregateRepository;
+        $this->eventBus = $eventBus;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function apply(string $aggregateIdentifier, callable $transaction) : Aggregate
+    {
+        $aggregate = $this->aggregateRepository->find($aggregateIdentifier);
+
+        if (null !== ($result = $transaction($aggregate))) {
+            if (!$aggregate instanceof Aggregate) {
+                throw new TransactionException('The transaction have to return `null` or with an `Aggregate` object');
+            }
+
+            $aggregate = $result;
+        }
+
+        foreach ($aggregate->raisedEvents() as $event) {
+            $this->eventBus->handle($event);
+        }
+
+        return $aggregate;
+    }
+}
diff --git a/src/ContinuousPipe/Events/Transaction/TransactionException.php b/src/ContinuousPipe/Events/Transaction/TransactionException.php
new file mode 100644
index 0000000..96f51fd
--- /dev/null
+++ b/src/ContinuousPipe/Events/Transaction/TransactionException.php
@@ -0,0 +1,7 @@
+<?php
+
+namespace ContinuousPipe\Events\Transaction;
+
+class TransactionException extends \Exception
+{
+}
diff --git a/src/ContinuousPipe/Events/Transaction/TransactionManager.php b/src/ContinuousPipe/Events/Transaction/TransactionManager.php
new file mode 100644
index 0000000..d5124ba
--- /dev/null
+++ b/src/ContinuousPipe/Events/Transaction/TransactionManager.php
@@ -0,0 +1,24 @@
+<?php
+
+namespace ContinuousPipe\Events\Transaction;
+
+use ContinuousPipe\Events\Aggregate;
+
+interface TransactionManager
+{
+    /**
+     * Apply the following transaction on the given tide. This will put a lock on the tide,
+     * fetch it, run the transaction, dispatch the events, and release the lock.
+     *
+     * The `transaction` should be a callable that receives a `Aggregate` object
+     * as the first argument and return it.
+     *
+     * @param string $aggregateIdentifier
+     * @param callable $transaction
+     *
+     * @throws TransactionException
+     *
+     * @return Aggregate
+     */
+    public function apply(string $aggregateIdentifier, callable $transaction) : Aggregate;
+}