✨ [53543] Introduce reset Redis messenger connection

andrew-demb · andrew-demb · commit 433dad7e3ff6 · 2025-02-25T22:48:28.000+01:00
diff --git a/src/Symfony/Component/Messenger/Bridge/Redis/Transport/RedisTransport.php b/src/Symfony/Component/Messenger/Bridge/Redis/Transport/RedisTransport.php
@@ -18,12 +18,13 @@
 use Symfony\Component\Messenger\Transport\Serialization\SerializerInterface;
 use Symfony\Component\Messenger\Transport\SetupableTransportInterface;
 use Symfony\Component\Messenger\Transport\TransportInterface;
+use Symfony\Contracts\Service\ResetInterface;
 
 /**
  * @author Alexander Schranz <alexander@sulu.io>
  * @author Antoine Bluchet <soyuka@gmail.com>
  */
-class RedisTransport implements TransportInterface, KeepaliveReceiverInterface, SetupableTransportInterface, MessageCountAwareInterface
+class RedisTransport implements TransportInterface, KeepaliveReceiverInterface, SetupableTransportInterface, MessageCountAwareInterface, ResetInterface
 {
     private SerializerInterface $serializer;
     private RedisReceiver $receiver;
@@ -80,4 +81,9 @@ private function getSender(): RedisSender
     {
         return $this->sender ??= new RedisSender($this->connection, $this->serializer);
     }
+
+    public function reset(): void
+    {
+        $this->connection->reset();
+    }
 }

Original file line number	Diff line number	Diff line change
`@@ -18,12 +18,13 @@`
`18`	`18`	`use Symfony\Component\Messenger\Transport\Serialization\SerializerInterface;`
19	`19`	`use Symfony\Component\Messenger\Transport\SetupableTransportInterface;`
`20`	`20`	`use Symfony\Component\Messenger\Transport\TransportInterface;`
	`21`	`+use Symfony\Contracts\Service\ResetInterface;`
`21`	`22`
`22`	`23`	`/**`
`23`	`24`	`* @author Alexander Schranz <alexander@sulu.io>`
`24`	`25`	`* @author Antoine Bluchet <soyuka@gmail.com>`
`25`	`26`	`*/`
`26`		`-class RedisTransport implements TransportInterface, KeepaliveReceiverInterface, SetupableTransportInterface, MessageCountAwareInterface`
	`27`	`+class RedisTransport implements TransportInterface, KeepaliveReceiverInterface, SetupableTransportInterface, MessageCountAwareInterface, ResetInterface`
`27`	`28`	`{`
`28`	`29`	`private SerializerInterface $serializer;`
`29`	`30`	`private RedisReceiver $receiver;`
`@@ -80,4 +81,9 @@ private function getSender(): RedisSender`
`80`	`81`	`{`
`81`	`82`	`return $this->sender ??= new RedisSender($this->connection, $this->serializer);`
`82`	`83`	`}`
	`84`	`+`
	`85`	`+ public function reset(): void`
	`86`	`+ {`
	`87`	`+ $this->connection->reset();`
	`88`	`+ }`
`83`	`89`	`}`