From b754b10908db442b570a1c6c2d6ce9a64062e189 Mon Sep 17 00:00:00 2001
From: Robertbaelde <robert_baelde@hotmail.com>
Date: Sun, 23 Jan 2022 18:13:32 +0100
Subject: [PATCH] Allow for extension of message repositories

---
 .../DoctrineUuidV4MessageRepository.php            | 14 +++++++-------
 .../IlluminateUuidV4MessageRepository.php          | 14 +++++++-------
 2 files changed, 14 insertions(+), 14 deletions(-)

diff --git a/src/DoctrineV2MessageRepository/DoctrineUuidV4MessageRepository.php b/src/DoctrineV2MessageRepository/DoctrineUuidV4MessageRepository.php
index bb68485..8032b59 100644
--- a/src/DoctrineV2MessageRepository/DoctrineUuidV4MessageRepository.php
+++ b/src/DoctrineV2MessageRepository/DoctrineUuidV4MessageRepository.php
@@ -33,14 +33,14 @@
 
 class DoctrineUuidV4MessageRepository implements MessageRepository
 {
-    private TableSchema $tableSchema;
-    private UuidEncoder $uuidEncoder;
+    protected TableSchema $tableSchema;
+    protected UuidEncoder $uuidEncoder;
 
     public function __construct(
-        private Connection $connection,
-        private string $tableName,
-        private MessageSerializer $serializer,
-        private int $jsonEncodeOptions = 0,
+        protected Connection $connection,
+        protected string $tableName,
+        protected MessageSerializer $serializer,
+        protected int $jsonEncodeOptions = 0,
         ?TableSchema $tableSchema = null,
         ?UuidEncoder $uuidEncoder = null,
     ) {
@@ -161,7 +161,7 @@ private function createQueryBuilder(): QueryBuilder
     /**
      * @psalm-return Generator<Message>
      */
-    private function yieldMessagesFromPayloads(Traversable $payloads): Generator
+    protected function yieldMessagesFromPayloads(Traversable $payloads): Generator
     {
         foreach ($payloads as $payload) {
             yield $message = $this->serializer->unserializePayload(json_decode($payload['payload'], true));
diff --git a/src/IlluminateMessageRepository/IlluminateUuidV4MessageRepository.php b/src/IlluminateMessageRepository/IlluminateUuidV4MessageRepository.php
index 3ccd2a7..2bbdcca 100644
--- a/src/IlluminateMessageRepository/IlluminateUuidV4MessageRepository.php
+++ b/src/IlluminateMessageRepository/IlluminateUuidV4MessageRepository.php
@@ -23,14 +23,14 @@
 
 class IlluminateUuidV4MessageRepository implements MessageRepository
 {
-    private TableSchema $tableSchema;
-    private UuidEncoder $uuidEncoder;
+    protected TableSchema $tableSchema;
+    protected UuidEncoder $uuidEncoder;
 
     public function __construct(
-        private ConnectionInterface $connection,
-        private string $tableName,
-        private MessageSerializer $serializer,
-        private int $jsonEncodeOptions = 0,
+        protected ConnectionInterface $connection,
+        protected string $tableName,
+        protected MessageSerializer $serializer,
+        protected int $jsonEncodeOptions = 0,
         ?TableSchema $tableSchema = null,
         ?UuidEncoder $uuidEncoder = null,
     ) {
@@ -106,7 +106,7 @@ public function retrieveAllAfterVersion(AggregateRootId $id, int $aggregateRootV
     /**
      * @psalm-return Generator<Message>
      */
-    private function yieldMessagesForResult(Collection $result): Generator
+    protected function yieldMessagesForResult(Collection $result): Generator
     {
         foreach ($result as $row) {
             $message = $this->serializer->unserializePayload(json_decode($row->payload, true));