symfony
diff --git a/‎src/Symfony/Component/Messenger/Bridge/Doctrine/Transport/PostgreSqlConnection.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Doctrine/Transport/PostgreSqlConnection.php
+7-3Lines changed: 7 additions & 3 deletions b/‎src/Symfony/Component/Messenger/Bridge/Doctrine/Transport/PostgreSqlConnection.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Doctrine/Transport/PostgreSqlConnection.php
+7-3Lines changed: 7 additions & 3 deletions
@@ -73,9 +73,13 @@ public function get(): ?array
             $this->listening = true;
         }
 
-        $wrappedConnection = $this->driverConnection->getWrappedConnection();
-        if (!$wrappedConnection instanceof \PDO && $wrappedConnection instanceof DoctrinePdoConnection) {
-            $wrappedConnection = $wrappedConnection->getWrappedConnection();
+        if (method_exists($this->driverConnection, 'getNativeConnection')) {
+            $wrappedConnection = $this->driverConnection->getNativeConnection();
+        } else {
+            $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']);