symfony
diff --git a/‎src/Symfony/Component/Messenger/Tests/Transport/RedisExt/ConnectionTest.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Tests/Transport/RedisExt/ConnectionTest.php
+17-1Lines changed: 17 additions & 1 deletion b/‎src/Symfony/Component/Messenger/Tests/Transport/RedisExt/ConnectionTest.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Tests/Transport/RedisExt/ConnectionTest.php
+17-1Lines changed: 17 additions & 1 deletion
diff --git a/‎src/Symfony/Component/Messenger/Transport/RedisExt/Connection.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Transport/RedisExt/Connection.php
+1-1Lines changed: 1 addition & 1 deletion b/‎src/Symfony/Component/Messenger/Transport/RedisExt/Connection.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Transport/RedisExt/Connection.php
+1-1Lines changed: 1 addition & 1 deletion
@@ -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');
     }
 }
@@ -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 [
Original file line number	Diff line number	Diff line change
`@@ -102,7 +102,7 @@ public function get(): ?array`
`102`	`102`	`return $this->get();`
`103`	`103`	`}`
`104`	`104`
`105`		`- foreach ($messages[$this->stream] as $key => $message) {`
	`105`	`+ foreach ($messages[$this->stream] ?? [] as $key => $message) {`
`106`	`106`	`$redisEnvelope = \json_decode($message['message'], true);`
`107`	`107`
`108`	`108`	`return [`