From 3c1ac6af46361ae82b8999cb412a129e07642489 Mon Sep 17 00:00:00 2001 From: Nikita Koksharov Date: Mon, 31 Aug 2020 12:32:00 +0300 Subject: [PATCH] tests fixed --- .../src/test/java/org/redisson/RedissonTransferQueueTest.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/RedissonTransferQueueTest.java b/redisson/src/test/java/org/redisson/RedissonTransferQueueTest.java index 2ed909a57..a1c324c43 100644 --- a/redisson/src/test/java/org/redisson/RedissonTransferQueueTest.java +++ b/redisson/src/test/java/org/redisson/RedissonTransferQueueTest.java @@ -63,7 +63,7 @@ public class RedissonTransferQueueTest extends BaseTest { long time = System.currentTimeMillis(); queue.transfer(3); assertThat(takeExecuted.get()).isTrue(); - assertThat(System.currentTimeMillis() - time).isGreaterThan(2950); + assertThat(System.currentTimeMillis() - time).isGreaterThan(2850); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } diff --git a/redisson/src/test/java/org/redisson/rx/RedissonBlockingDequeRxTest.java b/redisson/src/test/java/org/redisson/rx/RedissonBlockingDequeRxTest.java index b356197cc..af864c775 100644 --- a/redisson/src/test/java/org/redisson/rx/RedissonBlockingDequeRxTest.java +++ b/redisson/src/test/java/org/redisson/rx/RedissonBlockingDequeRxTest.java @@ -51,7 +51,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, 1110L); + assertThat(System.currentTimeMillis() - start).isBetween(950L, 1150L); assertThat(redisTask).isNull(); }