feat: CLI relay all messages, not just the first 100

CHANGELOG.md

@@ -5,6 +5,7 @@
 * chore: static analysis fix
 * fix: change outbox primary key to bigint
 * feat: also listen to `WorkerMessageHandledEvent` for relaying messages
+* feat: CLI relay all messages, not just the first 100
 
 ## 2.5.0
 

packages/domain-event-outbox/src/Command/MessageRelayCommand.php

@@ -67,7 +67,9 @@ protected function execute(InputInterface $input, OutputInterface $output): int
             throw new \InvalidArgumentException('The manager name must be a string.');
         }
 
-        $this->messageRelay->relayMessages($managerName);
+        do {
+            $messagesRelayed = $this->messageRelay->relayMessages($managerName);
+        } while ($messagesRelayed > 0);
 
         return Command::SUCCESS;
     }

packages/domain-event-outbox/src/MessageRelay/MessageRelayAll.php

@@ -31,7 +31,9 @@ public function relayAll(): void
         $managerNames = $this->managerRegistry->getManagerNames();
 
         foreach ($managerNames as $managerName => $serviceId) {
-            $this->messageRelay->relayMessages($managerName);
+            do {
+                $messagesRelayed = $this->messageRelay->relayMessages($managerName);
+            } while ($messagesRelayed > 0);
         }
     }
 }