update: reconnect tests

Author: adm-bome

tests/Feature/QueueTest.php

@@ -15,7 +15,8 @@ public function setUp(): void
         parent::setUp();
 
         $this->withoutExceptionHandling([
-            AMQPChannelClosedException::class, AMQPConnectionClosedException::class, AMQPProtocolChannelException::class,
+            AMQPChannelClosedException::class, AMQPConnectionClosedException::class,
+            AMQPProtocolChannelException::class,
         ]);
     }
 
@@ -39,24 +40,4 @@ public function testWithoutReconnect(): void
         $this->expectException(AMQPChannelClosedException::class);
         $queue->push(new TestJob());
     }
-
-    public function testReconnect(): void
-    {
-        $this->markTestSkipped();
-
-        $queue = $this->connection('octane');
-
-        $queue->push(new TestJob());
-        sleep(1);
-        $this->assertSame(1, $queue->size());
-
-        // close connection
-        $queue->getConnection()->close();
-        $this->assertFalse($queue->getConnection()->isConnected());
-
-        $queue->push(new TestJob());
-        sleep(1);
-        $this->assertTrue($queue->getConnection()->isConnected());
-        $this->assertSame(2, $queue->size());
-    }
 }

tests/Functional/TestCase.php

@@ -3,6 +3,7 @@
 namespace VladimirYuldashev\LaravelQueueRabbitMQ\Tests\Functional;
 
 use Exception;
+use PhpAmqpLib\Channel\AMQPChannel;
 use ReflectionClass;
 use ReflectionException;
 use VladimirYuldashev\LaravelQueueRabbitMQ\Tests\TestCase as BaseTestCase;
@@ -234,4 +235,34 @@ protected function callProperty($object, string $property): mixed
 
         return $property->getValue($object);
     }
+
+    public function testConnectChannel(): void
+    {
+        $queue = $this->connection();
+        $this->assertFalse($queue->getConnection()->isConnected());
+
+        /** @var AMQPChannel $channel */
+        $channel = $this->callMethod($queue, 'getChannel');
+        $this->assertTrue($queue->getConnection()->isConnected());
+        $this->assertSame($channel, $this->callProperty($queue, 'channel'));
+        $this->assertTrue($channel->is_open());
+    }
+
+    public function testReconnect(): void
+    {
+        $queue = $this->connection();
+        $this->assertFalse($queue->getConnection()->isConnected());
+
+        // connect
+        $channel = $this->callMethod($queue, 'getChannel');
+        $this->assertTrue($queue->getConnection()->isConnected());
+        $this->assertSame($channel, $this->callProperty($queue, 'channel'));
+
+        // reconnect
+        $queue->getConnection()->close();
+        $this->assertFalse($queue->getConnection()->isConnected());
+        $this->callMethod($queue, 'reconnect');
+        $this->assertTrue($queue->getConnection()->isConnected());
+        $this->assertTrue($queue->getChannel()->is_open());
+    }
 }