symfony
diff --git a/‎src/Symfony/Component/Messenger/Bridge/Doctrine/Tests/Transport/PostgreSqlConnectionTest.php‎
Lines changed: 14 additions & 0 deletions b/‎src/Symfony/Component/Messenger/Bridge/Doctrine/Tests/Transport/PostgreSqlConnectionTest.php‎
Lines changed: 14 additions & 0 deletions
diff --git a/‎src/Symfony/Component/Messenger/Bridge/Doctrine/Transport/PostgreSqlConnection.php‎
Lines changed: 14 additions & 0 deletions b/‎src/Symfony/Component/Messenger/Bridge/Doctrine/Transport/PostgreSqlConnection.php‎
Lines changed: 14 additions & 0 deletions
@@ -119,7 +119,13 @@ public function countNotifyCalls()
         $connection->get();
         $connection->get();
 
+        $this->assertTrue($connection->isListening());
+
         $this->assertSame(2, $wrappedConnection->countNotifyCalls());
+
+        $connection->__destruct();
+
+        $this->assertFalse($connection->isListening());
     }
 
     public function testGetExtraSetupSqlWrongTable()
@@ -132,4 +138,12 @@ public function testGetExtraSetupSqlWrongTable()
         // don't set the _symfony_messenger_table_name option
         $this->assertSame([], $connection->getExtraSetupSqlForTable($table));
     }
+
+    public function testIsListeningReturnsFalseWhenGetHasNotBeenCalled()
+    {
+        $driverConnection = $this->createStub(\Doctrine\DBAL\Connection::class);
+        $connection = new PostgreSqlConnection(['table_name' => 'queue_table'], $driverConnection);
+
+        $this->assertFalse($connection->isListening());
+    }
 }
@@ -22,6 +22,8 @@
  */
 final class PostgreSqlConnection extends Connection
 {
+    private bool $listening = false;
+
     /**
      * * check_delayed_interval: The interval to check for delayed messages, in milliseconds. Set to 0 to disable checks. Default: 60000 (1 minute)
      * * get_notify_timeout: The length of time to wait for a response when calling PDO::pgsqlGetNotify (or Pdo\Pgsql::getNotify on PHP 8.4+), in milliseconds. Default: 0.
@@ -46,6 +48,11 @@ public function __destruct()
         $this->unlisten();
     }
 
+    public function isListening(): bool
+    {
+        return $this->listening;
+    }
+
     public function reset(): void
     {
         parent::reset();
@@ -62,6 +69,8 @@ public function get(): ?array
         // https://www.postgresql.org/docs/current/sql-syntax-lexical.html#SQL-SYNTAX-IDENTIFIERS
         $this->executeStatement(\sprintf('LISTEN "%s"', $this->configuration['table_name']));
 
+        $this->listening = true;
+
         // The condition should be removed once support for DBAL <3.3 is dropped
         if (method_exists($this->driverConnection, 'getNativeConnection')) {
             $wrappedConnection = $this->driverConnection->getNativeConnection();
@@ -91,6 +100,11 @@ public function get(): ?array
 
     private function unlisten(): void
     {
+        if (!$this->listening) {
+            return;
+        }
+
         $this->executeStatement(\sprintf('UNLISTEN "%s"', $this->configuration['table_name']));
+        $this->listening = false;
     }
 }