From a92e4562f161271e9b7fca47e7165e3b862392f3 Mon Sep 17 00:00:00 2001
From: mrniko <1104661+mrniko@users.noreply.github.com>
Date: Mon, 10 Mar 2025 13:48:54 +0300
Subject: [PATCH] test fixed

---
 .../src/test/java/org/redisson/RedissonTest.java     | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/redisson/src/test/java/org/redisson/RedissonTest.java b/redisson/src/test/java/org/redisson/RedissonTest.java
index c731d8bbf..a7c288a37 100644
--- a/redisson/src/test/java/org/redisson/RedissonTest.java
+++ b/redisson/src/test/java/org/redisson/RedissonTest.java
@@ -949,11 +949,23 @@ public class RedissonTest extends RedisDockerTest {
             b.get();
         }
 
+        List<RFuture<Integer>> futures = new ArrayList<>();
+        RBlockingQueue<Integer> bb = r.getBlockingQueue("test2");
+        for (int i = 0; i < 10; i++) {
+            RFuture<Integer> s = bb.takeAsync();
+            futures.add(s);
+        }
+
         long startTime = System.currentTimeMillis();
         r.shutdown(quietPeriod, timeOut, TimeUnit.MILLISECONDS);
         long shutdownTime = System.currentTimeMillis() - startTime;
 
         Assertions.assertTrue(shutdownTime > quietPeriod);
+
+        assertThat(futures).hasSize(10);
+        for (RFuture<Integer> future : futures) {
+            assertThat(future.exceptionNow().getMessage()).isEqualTo("Redisson is shutdown");
+        }
     }
 
 }