Increase RedisEntityListenerTest.onSlowPublish timeout

Signed-off-by: Steven Sheehy <steven.sheehy@hedera.com>
hashgraph · Jun 21, 2021 · 3ad4c55 · 3ad4c55
1 parent e84cafc
commit 3ad4c55
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...t/java/com/hedera/mirror/importer/parser/record/entity/redis/RedisEntityListenerTest.java b/...t/java/com/hedera/mirror/importer/parser/record/entity/redis/RedisEntityListenerTest.java
@@ -102,13 +102,13 @@ void onSlowPublish() {
 
         //then
         //Thread is blocked because queue is full, and publisher is blocked on first message.
-        verify(redisOperations, timeout(TIMEOUT_MILLIS).times(1))
+        verify(redisOperations, timeout(TIMEOUT_MILLIS * 5).times(1))
                 .executePipelined(any(SessionCallback.class));
         assertThat(saveCount.get()).isEqualTo(redisProperties.getQueueCapacity() + 1);
 
         latch.countDown();
         //All messages should be queued and published
-        verify(redisOperations, timeout(TIMEOUT_MILLIS).times(redisProperties.getQueueCapacity() + 2))
+        verify(redisOperations, timeout(TIMEOUT_MILLIS * 5).times(redisProperties.getQueueCapacity() + 2))
                 .executePipelined(any(SessionCallback.class));
         assertThat(saveCount.get()).isEqualTo(redisProperties.getQueueCapacity() + 2);
     }