Safe disconnect on spool connection.

Author: ZhukV

src/Connection/SpoolConnection.php

@@ -92,6 +92,11 @@ public function isConnected(): bool
 
     public function disconnect(): void
     {
+        if (!$this->originConnection) {
+            // Already disconnected.
+            return;
+        }
+
         $this->getOriginConnection()->disconnect();
         $this->notify();
 

src/Consumer/Spool/SpoolConsumer.php

@@ -114,6 +114,8 @@ private function flushMessages(MutableReceivedMessages $messages): void
                 }
             }
 
+            $messages->clear();
+
             $this->getQueue()->getChannel()->getConnection()->disconnect();
 
             throw $e;

tests/Functional/Adapter/SpoolConnectionTestCase.php

@@ -40,6 +40,26 @@ public function shouldSuccessConnect(): void
         $this->addToAssertionCount(1);
     }
 
+    #[Test]
+    public function shouldSuccessDisconnectTwice(): void
+    {
+        $connection = $this->makeSpoolConnectionFactory()->create();
+
+        self::assertFalse($connection->isConnected());
+
+        $connection->connect();
+
+        self::assertTrue($connection->isConnected());
+
+        $connection->disconnect();
+
+        self::assertFalse($connection->isConnected());
+
+        $connection->disconnect();
+
+        self::assertFalse($connection->isConnected());
+    }
+
     #[Test]
     public function shouldSuccessGetChannel(): void
     {