move MessageTest.php to Unit

src/Adapter.php

@@ -14,11 +14,12 @@
 final class Adapter implements AdapterInterface
 {
     public function __construct(
-        private QueueProviderInterface $provider,
+        private QueueProviderInterface     $provider,
         private MessageSerializerInterface $serializer,
-        private LoopInterface $loop,
-        private int $timeout = 3
-    ) {
+        private LoopInterface              $loop,
+        private int                        $timeout = 3
+    )
+    {
     }
 
     public function runExisting(callable $handlerCallback): void
@@ -66,15 +67,18 @@ public function push(MessageInterface $message): MessageInterface
 
     public function subscribe(callable $handlerCallback): void
     {
-        while ($this->loop->canContinue()) {
+        $continue = true;
+        while ($continue) {
             $message = $this->reserve();
             if (null === $message) {
+                $continue = $this->loop->canContinue();
                 continue;
             }
 
             $result = $handlerCallback($message);
-            if ($result) {
-                $this->provider->delete((string) $message->getId());
+            $this->provider->delete((string) $message->getId());
+            if (!$result) {
+                $continue = false;
             }
         }
     }
@@ -99,4 +103,9 @@ private function reserve(): ?IdEnvelope
 
         return $envelope;
     }
+
+    public function getChannelName(): string
+    {
+        return $this->provider->getChannelName();
+    }
 }

src/QueueProvider.php

@@ -17,7 +17,8 @@ class QueueProvider implements QueueProviderInterface
     public function __construct(
         private \Redis $redis, //redis connection,
         private string $channelName = self::DEFAULT_CHANNEL_NAME
-    ) {
+    )
+    {
     }
 
     /**
@@ -145,4 +146,9 @@ private function checkConnection(): void
             throw new NotConnectedRedisException('Redis is not connected.');
         }
     }
+
+    public function getChannelName(): string
+    {
+        return $this->channelName;
+    }
 }

src/QueueProviderInterface.php

@@ -20,4 +20,6 @@ public function existInWaiting(int $id): bool;
     public function existInReserved(int $id): bool;
 
     public function withChannelName(string $channelName): self;
+
+    public function getChannelName(): string;
 }