[Messenger] Fix undefined index on read timeout

Author: Robin Chalas

Tests/Transport/RedisExt/ConnectionTest.php

@@ -115,7 +115,8 @@ public function testUnexpectedRedisError()
 
     public function testGetAfterReject()
     {
-        $connection = Connection::fromDsn('redis://localhost/messenger-rejectthenget');
+        $redis = new \Redis();
+        $connection = Connection::fromDsn('redis://localhost/messenger-rejectthenget', [], $redis);
         try {
             $connection->setup();
         } catch (TransportException $e) {
@@ -129,5 +130,20 @@ public function testGetAfterReject()
 
         $connection = Connection::fromDsn('redis://localhost/messenger-rejectthenget');
         $this->assertNotNull($connection->get());
+
+        $redis->del('messenger-rejectthenget');
+    }
+
+    public function testBlockingTimeout()
+    {
+        $redis = new \Redis();
+        $connection = Connection::fromDsn('redis://localhost/messenger-blockingtimeout', ['blocking_timeout' => 1], $redis);
+        try {
+            $connection->setup();
+        } catch (TransportException $e) {
+        }
+
+        $this->assertNull($connection->get());
+        $redis->del('messenger-blockingtimeout');
     }
 }

Transport/RedisExt/Connection.php

@@ -102,7 +102,7 @@ public function get(): ?array
             return $this->get();
         }
 
-        foreach ($messages[$this->stream] as $key => $message) {
+        foreach ($messages[$this->stream] ?? [] as $key => $message) {
             $redisEnvelope = \json_decode($message['message'], true);
 
             return [