tests: make RedisUnavailabilityTest work in pipeline

camunda-community-hub · Nov 28, 2023 · 1c0705b · 1c0705b
1 parent 2e421b7
commit 1c0705b
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/exporter/src/test/java/io/zeebe/redis/RedisUnavailabilityTest.java b/exporter/src/test/java/io/zeebe/redis/RedisUnavailabilityTest.java
@@ -58,13 +58,17 @@ public void cleanUp() {
   @Test
   public void worksCorrectIfRedisIsTemporarilyUnavailable() throws Exception {
     // given
+    WaitingConsumer consumer = new WaitingConsumer();
+    zeebeContainer.followOutput(consumer);
+    consumer.waitUntil(frame ->
+            frame.getUtf8String().contains("Successfully connected Redis exporter"), 10, TimeUnit.SECONDS);
+
     redisConnection.close();
     redisClient.shutdown();
     zeebeContainer.getRedisContainer().stop();
-    WaitingConsumer consumer = new WaitingConsumer();
-    zeebeContainer.followOutput(consumer);
     consumer.waitUntil(frame ->
-            frame.getUtf8String().contains("Connection refused: redis"), 10, TimeUnit.SECONDS);
+            frame.getUtf8String().contains("Cannot reconnect to [redis"), 10, TimeUnit.SECONDS);
+
     zeebeContainer.getClient().newDeployResourceCommand().addProcessModel(WORKFLOW, "process.bpmn").send().join();
     zeebeContainer.getClient().newDeployResourceCommand().addProcessModel(WORKFLOW, "process2.bpmn").send().join();
     Thread.sleep(1000);