symfony
diff --git a/‎src/Symfony/Bundle/FrameworkBundle/DependencyInjection/FrameworkExtension.php
Lines changed: 1 addition & 0 deletions b/‎src/Symfony/Bundle/FrameworkBundle/DependencyInjection/FrameworkExtension.php
Lines changed: 1 addition & 0 deletions
diff --git a/‎src/Symfony/Bundle/FrameworkBundle/Tests/DependencyInjection/FrameworkExtensionTestCase.php
Lines changed: 1 addition & 0 deletions b/‎src/Symfony/Bundle/FrameworkBundle/Tests/DependencyInjection/FrameworkExtensionTestCase.php
Lines changed: 1 addition & 0 deletions
diff --git a/‎src/Symfony/Component/Messenger/Bridge/Redis/Transport/Connection.php
Lines changed: 13 additions & 6 deletions b/‎src/Symfony/Component/Messenger/Bridge/Redis/Transport/Connection.php
Lines changed: 13 additions & 6 deletions
@@ -2368,6 +2368,7 @@ private function registerMessengerConfiguration(array $config, ContainerBuilder
                     'alias' => $name,
                     'is_failure_transport' => \in_array($name, $failureTransports, true),
                 ])
+                ->addTag('kernel.reset', ['method' => 'reset', 'on_invalid' => 'ignore'])
             ;
             $container->setDefinition($transportId = 'messenger.transport.'.$name, $transportDefinition);
             $senderAliases[$name] = $transportId;
 
@@ -948,6 +948,7 @@ public function testMessengerTransports()
         $container = $this->createContainerFromFile('messenger_transports');
         $this->assertTrue($container->hasDefinition('messenger.transport.default'));
         $this->assertTrue($container->getDefinition('messenger.transport.default')->hasTag('messenger.receiver'));
+        $this->assertTrue($container->getDefinition('messenger.transport.default')->hasTag('kernel.reset'));
         $this->assertEquals([
             ['alias' => 'default', 'is_failure_transport' => false], ], $container->getDefinition('messenger.transport.default')->getTag('messenger.receiver'));
         $transportArguments = $container->getDefinition('messenger.transport.default')->getArguments();
 
@@ -16,6 +16,7 @@
 use Symfony\Component\Messenger\Exception\InvalidArgumentException;
 use Symfony\Component\Messenger\Exception\LogicException;
 use Symfony\Component\Messenger\Exception\TransportException;
+use Symfony\Contracts\Service\ResetInterface;
 
 /**
  * A Redis connection.
@@ -28,7 +29,7 @@
  *
  * @final
  */
-class Connection
+class Connection implements ResetInterface
 {
     private const DEFAULT_OPTIONS = [
         'host' => '127.0.0.1',
@@ -55,7 +56,8 @@ class Connection
         'ssl' => null, // see https://php.net/context.ssl
     ];
 
-    private \Redis|Relay|\RedisCluster|\Closure $redis;
+    private \Redis|Relay|\RedisCluster|null $redis = null;
+    private \Closure $redisInitializer;
     private string $stream;
     private string $queue;
     private string $group;
@@ -112,9 +114,9 @@ public function __construct(array $options, \Redis|Relay|\RedisCluster|null $red
 
         if ((\is_array($host) && null === $sentinelMaster) || $redis instanceof \RedisCluster) {
             $hosts = \is_string($host) ? [$host.':'.$port] : $host; // Always ensure we have an array
-            $this->redis = static fn () => self::initializeRedisCluster($redis, $hosts, $auth, $options);
+            $this->redisInitializer = static fn () => self::initializeRedisCluster($redis, $hosts, $auth, $options);
         } else {
-            $this->redis = static function () use ($redis, $sentinelMaster, $host, $port, $options, $auth) {
+            $this->redisInitializer = static function () use ($redis, $sentinelMaster, $host, $port, $options, $auth) {
                 if (null !== $sentinelMaster) {
                     $sentinelClass = \extension_loaded('redis') ? \RedisSentinel::class : Sentinel::class;
                     $hostIndex = 0;
@@ -737,10 +739,15 @@ private function rawCommand(string $command, ...$arguments): mixed
 
     private function getRedis(): \Redis|Relay|\RedisCluster
     {
-        if ($this->redis instanceof \Closure) {
-            $this->redis = ($this->redis)();
+        if (!$this->redis) {
+            $this->redis = ($this->redisInitializer)();
         }
 
         return $this->redis;
     }
+
+    public function reset(): void
+    {
+        $this->redis = null;
+    }
 }
Original file line number	Diff line number	Diff line change
`@@ -2368,6 +2368,7 @@ private function registerMessengerConfiguration(array $config, ContainerBuilder`
`2368`	`2368`	`'alias' => $name,`
`2369`	`2369`	`'is_failure_transport' => \in_array($name, $failureTransports, true),`
`2370`	`2370`	`])`
	`2371`	`+ ->addTag('kernel.reset', ['method' => 'reset', 'on_invalid' => 'ignore'])`
`2371`	`2372`	`;`
`2372`	`2373`	`$container->setDefinition($transportId = 'messenger.transport.'.$name, $transportDefinition);`
`2373`	`2374`	`$senderAliases[$name] = $transportId;`