[camel] branch main updated: Fix flaky test

[davsclaus]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/main by this push:
     new 9512fab  Fix flaky test
9512fab is described below

commit 9512fabceb932596c39e4a6432532207dced39fa
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Fri Jan 14 07:13:18 2022 +0100

    Fix flaky test
---
 .../aggregator/AggregateCompletionOnlyOneTest.java       | 16 +++++++++++-----
 1 file changed, 11 insertions(+), 5 deletions(-)

diff --git 
a/core/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateCompletionOnlyOneTest.java
 
b/core/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateCompletionOnlyOneTest.java
index 7ca55ad..93dcf00 100644
--- 
a/core/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateCompletionOnlyOneTest.java
+++ 
b/core/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateCompletionOnlyOneTest.java
@@ -16,6 +16,7 @@
  */
 package org.apache.camel.processor.aggregator;
 
+import java.time.Duration;
 import java.util.Set;
 
 import org.apache.camel.CamelContext;
@@ -25,6 +26,7 @@ import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.component.mock.MockEndpoint;
 import org.apache.camel.processor.BodyInAggregatingStrategy;
 import org.apache.camel.spi.AggregationRepository;
+import org.awaitility.Awaitility;
 import org.junit.jupiter.api.Test;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
@@ -45,11 +47,15 @@ public class AggregateCompletionOnlyOneTest extends 
ContextTestSupport {
 
         assertMockEndpointsSatisfied();
 
-        assertEquals(4, repo.getGet());
-        // add and remove is not in use as we are completed immediately
-        assertEquals(0, repo.getAdd());
-        assertEquals(0, repo.getRemove());
-        assertEquals(4, repo.getConfirm());
+        Awaitility.await().atMost(Duration.ofSeconds(2))
+                .untilAsserted(
+                        () -> {
+                            assertEquals(4, repo.getGet());
+                            // add and remove is not in use as we are 
completed immediately
+                            assertEquals(0, repo.getAdd());
+                            assertEquals(0, repo.getRemove());
+                            assertEquals(4, repo.getConfirm());
+                        });
     }
 
     @Override