symfony
diff --git a/‎src/Symfony/Component/Messenger/Bridge/Redis/Tests/Transport/RedisExtIntegrationTest.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Redis/Tests/Transport/RedisExtIntegrationTest.php
+13Lines changed: 13 additions & 0 deletions b/‎src/Symfony/Component/Messenger/Bridge/Redis/Tests/Transport/RedisExtIntegrationTest.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Redis/Tests/Transport/RedisExtIntegrationTest.php
+13Lines changed: 13 additions & 0 deletions
diff --git a/‎src/Symfony/Component/Messenger/Bridge/Redis/Transport/Connection.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Redis/Transport/Connection.php
+5Lines changed: 5 additions & 0 deletions b/‎src/Symfony/Component/Messenger/Bridge/Redis/Transport/Connection.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Redis/Transport/Connection.php
+5Lines changed: 5 additions & 0 deletions
diff --git a/‎src/Symfony/Component/Messenger/Bridge/Redis/Transport/RedisReceiver.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Redis/Transport/RedisReceiver.php
+10-1Lines changed: 10 additions & 1 deletion b/‎src/Symfony/Component/Messenger/Bridge/Redis/Transport/RedisReceiver.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Redis/Transport/RedisReceiver.php
+10-1Lines changed: 10 additions & 1 deletion
diff --git a/‎src/Symfony/Component/Messenger/Bridge/Redis/Transport/RedisTransport.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Redis/Transport/RedisTransport.php
+10-1Lines changed: 10 additions & 1 deletion b/‎src/Symfony/Component/Messenger/Bridge/Redis/Transport/RedisTransport.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Redis/Transport/RedisTransport.php
+10-1Lines changed: 10 additions & 1 deletion
@@ -338,6 +338,19 @@ public function testGetAfterReject()
 
         $redis->del('messenger-rejectthenget');
     }
+    public function testItCountMessages()
+    {
+        $this->connection->add('{"message": "Hi"}', ['type' => DummyMessage::class]);
+        $this->connection->add('{"message": "Hi"}', ['type' => DummyMessage::class]);
+        $this->connection->add('{"message": "Hi"}', ['type' => DummyMessage::class]);
+
+        $this->assertSame(3, $this->connection->getMessageCount());
+
+        $message = $this->connection->get();
+        $this->connection->ack($message['id']);
+
+        $this->assertSame(2, $this->connection->getMessageCount());
+    }
 
     private function getConnectionGroup(Connection $connection): string
     {
 
@@ -521,6 +521,11 @@ public function cleanup(): void
         }
     }
 
+    public function getMessageCount(): int
+    {
+        return $this->connection->xlen($this->stream);
+    }
+
     private function rawCommand(string $command, ...$arguments): mixed
     {
         try {
 
@@ -14,6 +14,7 @@
 use Symfony\Component\Messenger\Envelope;
 use Symfony\Component\Messenger\Exception\LogicException;
 use Symfony\Component\Messenger\Exception\MessageDecodingFailedException;
+use Symfony\Component\Messenger\Transport\Receiver\MessageCountAwareInterface;
 use Symfony\Component\Messenger\Transport\Receiver\ReceiverInterface;
 use Symfony\Component\Messenger\Transport\Serialization\PhpSerializer;
 use Symfony\Component\Messenger\Transport\Serialization\SerializerInterface;
@@ -22,7 +23,7 @@
  * @author Alexander Schranz <alexander@sulu.io>
  * @author Antoine Bluchet <soyuka@gmail.com>
  */
-class RedisReceiver implements ReceiverInterface
+class RedisReceiver implements ReceiverInterface, MessageCountAwareInterface
 {
     private Connection $connection;
     private SerializerInterface $serializer;
@@ -84,6 +85,14 @@ public function reject(Envelope $envelope): void
         $this->connection->reject($this->findRedisReceivedStamp($envelope)->getId());
     }
 
+    /**
+     * {@inheritdoc}
+     */
+    public function getMessageCount(): int
+    {
+        return $this->connection->getMessageCount();
+    }
+
     private function findRedisReceivedStamp(Envelope $envelope): RedisReceivedStamp
     {
         /** @var RedisReceivedStamp|null $redisReceivedStamp */
 
@@ -12,6 +12,7 @@
 namespace Symfony\Component\Messenger\Bridge\Redis\Transport;
 
 use Symfony\Component\Messenger\Envelope;
+use Symfony\Component\Messenger\Transport\Receiver\MessageCountAwareInterface;
 use Symfony\Component\Messenger\Transport\Serialization\PhpSerializer;
 use Symfony\Component\Messenger\Transport\Serialization\SerializerInterface;
 use Symfony\Component\Messenger\Transport\SetupableTransportInterface;
@@ -21,7 +22,7 @@
  * @author Alexander Schranz <alexander@sulu.io>
  * @author Antoine Bluchet <soyuka@gmail.com>
  */
-class RedisTransport implements TransportInterface, SetupableTransportInterface
+class RedisTransport implements TransportInterface, SetupableTransportInterface, MessageCountAwareInterface
 {
     private SerializerInterface $serializer;
     private Connection $connection;
@@ -74,6 +75,14 @@ public function setup(): void
         $this->connection->setup();
     }
 
+    /**
+     * {@inheritdoc}
+     */
+    public function getMessageCount(): int
+    {
+        return $this->getReceiver()->getMessageCount();
+    }
+
     private function getReceiver(): RedisReceiver
     {
         return $this->receiver ??= new RedisReceiver($this->connection, $this->serializer);
Original file line number	Diff line number	Diff line change
`@@ -521,6 +521,11 @@ public function cleanup(): void`
`521`	`521`	`}`
`522`	`522`	`}`
`523`	`523`
	`524`	`+ public function getMessageCount(): int`
	`525`	`+ {`
	`526`	`+ return $this->connection->xlen($this->stream);`
	`527`	`+ }`
	`528`	`+`
`524`	`529`	`private function rawCommand(string $command, ...$arguments): mixed`
`525`	`530`	`{`
`526`	`531`	`try {`