From d77ea3e4eaf16efebb5b7a5e3b1004afcdf7c671 Mon Sep 17 00:00:00 2001 From: Nikita Koksharov Date: Fri, 3 Sep 2021 15:02:23 +0300 Subject: [PATCH] tests fixed --- redisson/src/test/java/org/redisson/RedissonTest.java | 2 +- .../test/java/org/redisson/rx/RedissonBlockingDequeRxTest.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/redisson/src/test/java/org/redisson/RedissonTest.java b/redisson/src/test/java/org/redisson/RedissonTest.java index 1b1cffdf7..6f2266fbb 100644 --- a/redisson/src/test/java/org/redisson/RedissonTest.java +++ b/redisson/src/test/java/org/redisson/RedissonTest.java @@ -83,7 +83,7 @@ public class RedissonTest extends BaseTest { } ex.shutdown(); - assertThat(ex.awaitTermination(5, TimeUnit.SECONDS)).isTrue(); + assertThat(ex.awaitTermination(7, TimeUnit.SECONDS)).isTrue(); inst.shutdown(); } diff --git a/redisson/src/test/java/org/redisson/rx/RedissonBlockingDequeRxTest.java b/redisson/src/test/java/org/redisson/rx/RedissonBlockingDequeRxTest.java index 0f5c763bb..3c1803c3e 100644 --- a/redisson/src/test/java/org/redisson/rx/RedissonBlockingDequeRxTest.java +++ b/redisson/src/test/java/org/redisson/rx/RedissonBlockingDequeRxTest.java @@ -53,7 +53,7 @@ public class RedissonBlockingDequeRxTest extends BaseRxTest { RBlockingDequeRx blockingDeque = redisson.getBlockingDeque("blocking_deque"); long start = System.currentTimeMillis(); String redisTask = sync(blockingDeque.pollLastAndOfferFirstTo("deque", 1, TimeUnit.SECONDS)); - assertThat(System.currentTimeMillis() - start).isBetween(950L, 1150L); + assertThat(System.currentTimeMillis() - start).isBetween(950L, 1200L); assertThat(redisTask).isNull(); }