make MemoryQueueClient::$memory as public

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

Hide file tree

Showing 3 changed files with 1 addition and 23 deletions.
diff --git a/src/Aws/Sqs/SqsQueue.php b/src/Aws/Sqs/SqsQueue.php
@@ -59,20 +59,4 @@ 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
@@ -12,7 +12,7 @@
 
 final class MemoryQueueClient implements QueueClient, Countable
 {
-    private array $memory = [];
+    public array $memory = [];
 
     public function sendMessage(Message $message, MessageMetadata $metadata): void
     {
@@ -31,9 +31,4 @@ 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,5 +7,4 @@ interface QueueClient
 {
     public function sendMessage(Message $message, MessageMetadata $metadata): void;
     public function getMessages(int $numberOfMessages = 10): array;
-    public function getAllMessages(): array;
 }