symfony
diff --git a/‎src/Symfony/Component/Messenger/Tests/Transport/Doctrine/ConnectionTest.php
Lines changed: 13 additions & 2 deletions b/‎src/Symfony/Component/Messenger/Tests/Transport/Doctrine/ConnectionTest.php
Lines changed: 13 additions & 2 deletions
diff --git a/‎src/Symfony/Component/Messenger/Transport/Doctrine/Connection.php
Lines changed: 5 additions & 0 deletions b/‎src/Symfony/Component/Messenger/Transport/Doctrine/Connection.php
Lines changed: 5 additions & 0 deletions
@@ -13,6 +13,7 @@
 
 use Doctrine\DBAL\Abstraction\Result;
 use Doctrine\DBAL\DBALException;
+use Doctrine\DBAL\Exception;
 use Doctrine\DBAL\Platforms\AbstractPlatform;
 use Doctrine\DBAL\Query\QueryBuilder;
 use Doctrine\DBAL\Schema\AbstractSchemaManager;
@@ -87,7 +88,12 @@ public function testItThrowsATransportExceptionIfItCannotAcknowledgeMessage()
     {
         $this->expectException('Symfony\Component\Messenger\Exception\TransportException');
         $driverConnection = $this->getDBALConnectionMock();
-        $driverConnection->method('delete')->willThrowException(new DBALException());
+
+        if (class_exists(Exception::class)) {
+            $driverConnection->method('delete')->willThrowException(new Exception());
+        } else {
+            $driverConnection->method('delete')->willThrowException(new DBALException());
+        }
 
         $connection = new Connection([], $driverConnection);
         $connection->ack('dummy_id');
@@ -97,7 +103,12 @@ public function testItThrowsATransportExceptionIfItCannotRejectMessage()
     {
         $this->expectException('Symfony\Component\Messenger\Exception\TransportException');
         $driverConnection = $this->getDBALConnectionMock();
-        $driverConnection->method('delete')->willThrowException(new DBALException());
+
+        if (class_exists(Exception::class)) {
+            $driverConnection->method('delete')->willThrowException(new Exception());
+        } else {
+            $driverConnection->method('delete')->willThrowException(new DBALException());
+        }
 
         $connection = new Connection([], $driverConnection);
         $connection->reject('dummy_id');
 
@@ -14,6 +14,7 @@
 use Doctrine\DBAL\Connection as DBALConnection;
 use Doctrine\DBAL\DBALException;
 use Doctrine\DBAL\Driver\Result;
+use Doctrine\DBAL\Exception;
 use Doctrine\DBAL\Exception\TableNotFoundException;
 use Doctrine\DBAL\Query\QueryBuilder;
 use Doctrine\DBAL\Schema\Comparator;
@@ -205,6 +206,8 @@ public function ack(string $id): bool
     {
         try {
             return $this->driverConnection->delete($this->configuration['table_name'], ['id' => $id]) > 0;
+        } catch (Exception $exception) {
+            throw new TransportException($exception->getMessage(), 0, $exception);
         } catch (DBALException $exception) {
             throw new TransportException($exception->getMessage(), 0, $exception);
         }
@@ -214,6 +217,8 @@ public function reject(string $id): bool
     {
         try {
             return $this->driverConnection->delete($this->configuration['table_name'], ['id' => $id]) > 0;
+        } catch (Exception $exception) {
+            throw new TransportException($exception->getMessage(), 0, $exception);
         } catch (DBALException $exception) {
             throw new TransportException($exception->getMessage(), 0, $exception);
         }
Original file line number	Diff line number	Diff line change
`@@ -14,6 +14,7 @@`
`14`	`14`	`use Doctrine\DBAL\Connection as DBALConnection;`
`15`	`15`	`use Doctrine\DBAL\DBALException;`
`16`	`16`	`use Doctrine\DBAL\Driver\Result;`
	`17`	`+use Doctrine\DBAL\Exception;`
`17`	`18`	`use Doctrine\DBAL\Exception\TableNotFoundException;`
`18`	`19`	`use Doctrine\DBAL\Query\QueryBuilder;`
`19`	`20`	`use Doctrine\DBAL\Schema\Comparator;`
`@@ -205,6 +206,8 @@ public function ack(string $id): bool`
`205`	`206`	`{`
`206`	`207`	`try {`
`207`	`208`	`return $this->driverConnection->delete($this->configuration['table_name'], ['id' => $id]) > 0;`
	`209`	`+ } catch (Exception $exception) {`
	`210`	`+ throw new TransportException($exception->getMessage(), 0, $exception);`
`208`	`211`	`} catch (DBALException $exception) {`
`209`	`212`	`throw new TransportException($exception->getMessage(), 0, $exception);`
`210`	`213`	`}`
`@@ -214,6 +217,8 @@ public function reject(string $id): bool`
`214`	`217`	`{`
`215`	`218`	`try {`
`216`	`219`	`return $this->driverConnection->delete($this->configuration['table_name'], ['id' => $id]) > 0;`
	`220`	`+ } catch (Exception $exception) {`
	`221`	`+ throw new TransportException($exception->getMessage(), 0, $exception);`
`217`	`222`	`} catch (DBALException $exception) {`
`218`	`223`	`throw new TransportException($exception->getMessage(), 0, $exception);`
`219`	`224`	`}`