Add new QueueClient::getAllMessages() method

landingi · Feb 29, 2024 · fd6bfbd · fd6bfbd
1 parent 6e53640
commit fd6bfbd
Show file tree

Hide file tree

Showing 3 changed files with 22 additions and 0 deletions.
diff --git a/src/Aws/Sqs/SqsQueue.php b/src/Aws/Sqs/SqsQueue.php
@@ -59,4 +59,20 @@ public function getMessages(int $numberOfMessages = 10): array
 
         return [];
     }
+
+    public function getAllMessages(): array
+    {
+        $response = $this->client->receiveMessage([
+            'QueueUrl' => sprintf('%s/%s', $this->queueEndpoint, $this->queueName),
+        ]);
+
+        if (is_array($response->search('Messages'))) {
+            return array_map(
+                static fn ($message) => $message['Body'],
+                $response->search('Messages')
+            );
+        }
+
+        return [];
+    }
 }
diff --git a/src/Memory/Queue/MemoryQueueClient.php b/src/Memory/Queue/MemoryQueueClient.php
@@ -31,4 +31,9 @@ public function getMessages(int $numberOfMessages = 10): array
     {
         return array_splice($this->memory, 0, $numberOfMessages);
     }
+
+    public function getAllMessages(): array
+    {
+        return $this->memory;
+    }
 }
diff --git a/src/Queue/QueueClient.php b/src/Queue/QueueClient.php
@@ -7,4 +7,5 @@ interface QueueClient
 {
     public function sendMessage(Message $message, MessageMetadata $metadata): void;
     public function getMessages(int $numberOfMessages = 10): array;
+    public function getAllMessages(): array;
 }