bug #43630 [Messenger] Fix unwrapping the Postgres connection in DBAL 3 (derrabus)

fabpot · fabpot · commit 9f43121357bf · 2021-10-21T18:11:20.000+02:00
This PR was merged into the 5.3 branch. Discussion ---------- [Messenger] Fix unwrapping the Postgres connection in DBAL 3 | Q | A | ------------- | --- | Branch? | 5.3 | Bug fix? | yes | New feature? | no | Deprecations? | no | Tickets | Fix #43601 | License | MIT | Doc PR | N/A Commits ------- 95d5790 [Messenger] Fix unwrapping the Postgres connection in DBAL 3
diff --git a/src/Symfony/Component/Messenger/Bridge/Doctrine/Transport/PostgreSqlConnection.php b/src/Symfony/Component/Messenger/Bridge/Doctrine/Transport/PostgreSqlConnection.php
@@ -11,6 +11,7 @@
 
 namespace Symfony\Component\Messenger\Bridge\Doctrine\Transport;
 
+use Doctrine\DBAL\Driver\PDO\Connection as DoctrinePdoConnection;
 use Doctrine\DBAL\Schema\Table;
 
 /**
@@ -72,7 +73,12 @@ public function get(): ?array
             $this->listening = true;
         }
 
-        $notification = $this->driverConnection->getWrappedConnection()->pgsqlGetNotify(\PDO::FETCH_ASSOC, $this->configuration['get_notify_timeout']);
+        $wrappedConnection = $this->driverConnection->getWrappedConnection();
+        if (!$wrappedConnection instanceof \PDO && $wrappedConnection instanceof DoctrinePdoConnection) {
+            $wrappedConnection = $wrappedConnection->getWrappedConnection();
+        }
+
+        $notification = $wrappedConnection->pgsqlGetNotify(\PDO::FETCH_ASSOC, $this->configuration['get_notify_timeout']);
         if (
             // no notifications, or for another table or queue
             (false === $notification || $notification['message'] !== $this->configuration['table_name'] || $notification['payload'] !== $this->configuration['queue_name']) &&
