fix

Author: vjik

src/Queue.php

@@ -40,10 +40,7 @@ public function __construct(
 
     public function getChannel(): string
     {
-        if ($this->adapter === null) {
-            throw new LogicException('Adapter is not set.');
-        }
-
+        $this->checkAdapter();
         return $this->adapter->getChannel();
     }
 
@@ -86,7 +83,6 @@ public function run(int $max = 0): int
             return true;
         };
 
-        /** @psalm-suppress PossiblyNullReference */
         $this->adapter->runExisting($handlerCallback);
 
         $this->logger->info(
@@ -102,16 +98,13 @@ public function listen(): void
         $this->checkAdapter();
 
         $this->logger->info('Start listening to the queue.');
-        /** @psalm-suppress PossiblyNullReference */
         $this->adapter->subscribe(fn (MessageInterface $message) => $this->handle($message));
         $this->logger->info('Finish listening to the queue.');
     }
 
     public function status(string|int $id): JobStatus
     {
         $this->checkAdapter();
-
-        /** @psalm-suppress PossiblyNullReference */
         return $this->adapter->status($id);
     }
 
@@ -146,6 +139,9 @@ private function handle(MessageInterface $message): bool
         return $this->loop->canContinue();
     }
 
+    /**
+     * @psalm-assert AdapterInterface $this->adapter
+     */
     private function checkAdapter(): void
     {
         if ($this->adapter === null) {