rename message loader classes

patchlevel · Dec 5, 2024 · f3b413f · f3b413f
1 parent d28386d
commit f3b413f
Show file tree

Hide file tree

Showing 5 changed files with 7 additions and 7 deletions.
diff --git a/src/Subscription/Engine/DefaultSubscriptionEngine.php b/src/Subscription/Engine/DefaultSubscriptionEngine.php
@@ -45,7 +45,7 @@ public function __construct(
         if ($messageStore instanceof MessageLoader) {
             $this->messageLoader = $messageStore;
         } else {
-            $this->messageLoader = new DefaultMessageLoader($messageStore);
+            $this->messageLoader = new StoreMessageLoader($messageStore);
         }
 
         $this->subscriptionManager = new SubscriptionManager($subscriptionStore);

diff --git a/...ion/Engine/EventFilteredMessageLoader.php → ...ngine/EventFilteredStoreMessageLoader.php b/...ion/Engine/EventFilteredMessageLoader.php → ...ngine/EventFilteredStoreMessageLoader.php
@@ -16,7 +16,7 @@
 
 use function array_keys;
 
-final class EventFilteredMessageLoader implements MessageLoader
+final class EventFilteredStoreMessageLoader implements MessageLoader
 {
     public function __construct(
         private readonly Store $store,

diff --git a/...scription/Engine/DefaultMessageLoader.php → ...ubscription/Engine/StoreMessageLoader.php b/...scription/Engine/DefaultMessageLoader.php → ...ubscription/Engine/StoreMessageLoader.php
@@ -10,7 +10,7 @@
 use Patchlevel\EventSourcing\Store\Stream;
 use Patchlevel\EventSourcing\Subscription\Subscription;
 
-final class DefaultMessageLoader implements MessageLoader
+final class StoreMessageLoader implements MessageLoader
 {
     public function __construct(
         private readonly Store $store,

diff --git a/tests/Benchmark/SubscriptionEngineBench.php b/tests/Benchmark/SubscriptionEngineBench.php
@@ -14,7 +14,7 @@
 use Patchlevel\EventSourcing\Store\DoctrineDbalStore;
 use Patchlevel\EventSourcing\Store\Store;
 use Patchlevel\EventSourcing\Subscription\Engine\DefaultSubscriptionEngine;
-use Patchlevel\EventSourcing\Subscription\Engine\EventFilteredMessageLoader;
+use Patchlevel\EventSourcing\Subscription\Engine\EventFilteredStoreMessageLoader;
 use Patchlevel\EventSourcing\Subscription\Engine\SubscriptionEngine;
 use Patchlevel\EventSourcing\Subscription\Store\DoctrineSubscriptionStore;
 use Patchlevel\EventSourcing\Subscription\Subscriber\MetadataSubscriberAccessorRepository;
@@ -79,7 +79,7 @@ public function setUp(): void
         );
 
         $this->subscriptionEngine = new DefaultSubscriptionEngine(
-            new EventFilteredMessageLoader(
+            new EventFilteredStoreMessageLoader(
                 $this->store,
                 new AttributeEventMetadataFactory(),
                 $subscriberAccessorRepository,

diff --git a/tests/Integration/Subscription/SubscriptionTest.php b/tests/Integration/Subscription/SubscriptionTest.php
@@ -22,7 +22,7 @@
 use Patchlevel\EventSourcing\Store\StreamDoctrineDbalStore;
 use Patchlevel\EventSourcing\Subscription\Engine\CatchUpSubscriptionEngine;
 use Patchlevel\EventSourcing\Subscription\Engine\DefaultSubscriptionEngine;
-use Patchlevel\EventSourcing\Subscription\Engine\EventFilteredMessageLoader;
+use Patchlevel\EventSourcing\Subscription\Engine\EventFilteredStoreMessageLoader;
 use Patchlevel\EventSourcing\Subscription\Engine\SubscriptionEngineCriteria;
 use Patchlevel\EventSourcing\Subscription\RetryStrategy\ClockBasedRetryStrategy;
 use Patchlevel\EventSourcing\Subscription\RunMode;
@@ -97,7 +97,7 @@ public function testHappyPath(): void
         $subscriberRepository = new MetadataSubscriberAccessorRepository([new ProfileProjection($this->projectionConnection)]);
 
         $engine = new DefaultSubscriptionEngine(
-            new EventFilteredMessageLoader($store, new AttributeEventMetadataFactory(), $subscriberRepository),
+            new EventFilteredStoreMessageLoader($store, new AttributeEventMetadataFactory(), $subscriberRepository),
             $subscriptionStore,
             $subscriberRepository,
         );