diff --git a/redisson/src/test/java/org/redisson/RedissonBlockingQueueTest.java b/redisson/src/test/java/org/redisson/RedissonBlockingQueueTest.java index f55a5bc0a..1f69bb8c9 100644 --- a/redisson/src/test/java/org/redisson/RedissonBlockingQueueTest.java +++ b/redisson/src/test/java/org/redisson/RedissonBlockingQueueTest.java @@ -498,13 +498,11 @@ public class RedissonBlockingQueueTest extends RedissonQueueTest { Executors.newSingleThreadScheduledExecutor().schedule(() -> { RBlockingQueue queue2 = redisson.getBlockingQueue("queue:pollany1"); RBlockingQueue queue3 = redisson.getBlockingQueue("queue:pollany2"); - try { + Assertions.assertDoesNotThrow(() -> { queue3.put(2); queue1.put(1); queue2.put(3); - } catch (InterruptedException e) { - Assertions.fail(); - } + }); }, 3, TimeUnit.SECONDS); long s = System.currentTimeMillis();