Fix the method visibility check

Author: andrewmy

pkg/dbal/ManagerRegistryConnectionFactory.php

@@ -8,6 +8,7 @@
 use Doctrine\Persistence\ManagerRegistry;
 use Interop\Queue\ConnectionFactory;
 use Interop\Queue\Context;
+use ReflectionMethod;
 
 class ManagerRegistryConnectionFactory implements ConnectionFactory
 {
@@ -61,7 +62,10 @@ private function establishConnection(): Connection
     {
         /** @var Connection $connection */
         $connection = $this->registry->getConnection($this->config['connection_name']);
-        if (method_exists($connection, 'connect')) {
+        if (
+            method_exists($connection, 'connect')
+            && (new ReflectionMethod($connection, 'connect'))->isPublic()
+        ) {
             // DBAL < 4
             $connection->connect();
         } else {

pkg/enqueue-bundle/Consumption/Extension/DoctrinePingConnectionExtension.php

@@ -6,6 +6,7 @@
 use Doctrine\Persistence\ManagerRegistry;
 use Enqueue\Consumption\Context\MessageReceived;
 use Enqueue\Consumption\MessageReceivedExtensionInterface;
+use ReflectionMethod;
 
 class DoctrinePingConnectionExtension implements MessageReceivedExtensionInterface
 {
@@ -36,7 +37,10 @@ public function onMessageReceived(MessageReceived $context): void
             );
 
             $connection->close();
-            if (method_exists($connection, 'connect')) {
+            if (
+                method_exists($connection, 'connect')
+                && (new ReflectionMethod($connection, 'connect'))->isPublic()
+            ) {
                 // DBAL < 4
                 $connection->connect();
             } else {

pkg/enqueue-bundle/Tests/Unit/Consumption/Extension/DoctrinePingConnectionExtensionTest.php

@@ -14,6 +14,7 @@
 use Interop\Queue\Processor;
 use PHPUnit\Framework\MockObject\MockObject;
 use PHPUnit\Framework\TestCase;
+use ReflectionMethod;
 
 class DoctrinePingConnectionExtensionTest extends TestCase
 {
@@ -41,7 +42,10 @@ public function testShouldNotReconnectIfConnectionIsOK()
             ->expects($this->never())
             ->method('close')
         ;
-        if (method_exists(Connection::class, 'connect')) {
+        if (
+            method_exists(Connection::class, 'connect')
+            && (new ReflectionMethod(Connection::class, 'connect'))->isPublic()
+        ) {
             // DBAL < 4
             $connection->expects($this->never())
                 ->method('connect');
@@ -87,7 +91,10 @@ public function testShouldDoesReconnectIfConnectionFailed()
             ->expects($this->once())
             ->method('close')
         ;
-        if (method_exists(Connection::class, 'connect')) {
+        if (
+            method_exists(Connection::class, 'connect')
+            && (new ReflectionMethod(Connection::class, 'connect'))->isPublic()
+        ) {
             // DBAL < 4
             $connection->expects($this->once())
                 ->method('connect');