test: more stable ExporterDeleteAfterAcknowledgeTest on pipeline

camunda-community-hub · Nov 22, 2023 · 66f952b · 66f952b
1 parent 7b09fb8
commit 66f952b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/exporter/src/test/java/io/zeebe/redis/ExporterDeleteAfterAcknowledgeTest.java b/exporter/src/test/java/io/zeebe/redis/ExporterDeleteAfterAcknowledgeTest.java
@@ -74,7 +74,7 @@ public void shouldDeleteAfterAcknowledge() throws Exception {
     var delay = Duration.ofSeconds(3);
 
     // then: cleanup removed all messages except the last ones
-    await().atMost(Duration.ofSeconds(5)).pollDelay(delay).pollInterval(Duration.ofMillis(500))
+    await().atMost(Duration.ofSeconds(5)).pollDelay(delay).pollInterval(Duration.ofMillis(500)).pollInSameThread()
             .untilAsserted(() -> assertThat(redisConnection.sync().xlen("zeebe:DEPLOYMENT")).isLessThan(xlen));
 
   }
@@ -98,7 +98,7 @@ public void shouldNotDeleteWhenConsumedButNotAcknowledged() throws Exception {
     var delay = Duration.ofSeconds(3);
 
     // then: cleanup did not remove messages
-    await().atMost(Duration.ofSeconds(5)).pollDelay(delay).pollInterval(Duration.ofMillis(500))
+    await().atMost(Duration.ofSeconds(5)).pollDelay(delay).pollInterval(Duration.ofMillis(500)).pollInSameThread()
             .untilAsserted(() -> assertThat(redisConnection.sync().xlen("zeebe:DEPLOYMENT")).isGreaterThanOrEqualTo(xlen));
   }