test fixed

pull/4640/merge
Nikita Koksharov 2 years ago
parent 50075a48c5
commit 35f1ffde2c

@ -69,7 +69,7 @@ public class RedissonBlockingDequeTest extends BaseTest {
@Test
public void testPollLastAndOfferFirstTo() throws InterruptedException {
RBlockingDeque<String> blockingDeque = redisson.getBlockingDeque("blocking_deque");
Awaitility.await().between(Duration.ofMillis(1000), Duration.ofMillis(1200)).untilAsserted(() -> {
Awaitility.await().between(Duration.ofMillis(1000), Duration.ofMillis(1300)).untilAsserted(() -> {
String redisTask = blockingDeque.pollLastAndOfferFirstTo("deque", 1, TimeUnit.SECONDS);
assertThat(redisTask).isNull();
});

Loading…
Cancel
Save