CAMEL-19528: Replace CountDownLatch with Awaitility in camel-jpa tests (#24411)

Replace flaky CountDownLatch-based synchronization with Awaitility
polling in JPA consumer tests. The CountDownLatch pattern caused
intermittent hangs and timeouts in CI because the JPA consumer's
scheduled polling (1s initial delay, 500ms interval) could miss the
fixed deadline under load.

Changes:
- JpaWithNamedQueryTest: replace CountDownLatch + latch.await() with
  Awaitility await().untilAsserted()
- JpaTest: same CountDownLatch to Awaitility migration
- JpaWithNamedQueryAndParametersTest: same migration
- Re-enable JpaWithQueryTest, JpaWithNativeQueryTest, and
  JpaWithNativeQueryWithResultClassTest by removing
  @DisabledIfSystemProperty annotations (the underlying timing
  issue in their parent class is now fixed)
- Mark receivedExchange fields as volatile for thread-safe publication

Co-authored-by: Claude Opus 4.6 <noreply@anthropic.com>

Author: gnodet

components/camel-jpa/src/test/java/org/apache/camel/component/jpa/JpaTest.java

@@ -18,7 +18,6 @@
 
 import java.util.ArrayList;
 import java.util.List;
-import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.TimeUnit;
 
 import jakarta.persistence.EntityManager;
@@ -41,6 +40,7 @@
 import org.springframework.transaction.support.TransactionCallback;
 import org.springframework.transaction.support.TransactionTemplate;
 
+import static org.awaitility.Awaitility.await;
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertNotNull;
 import static org.junit.jupiter.api.Assertions.assertTrue;
@@ -55,8 +55,7 @@ public class JpaTest {
     protected EntityManager entityManager;
     protected TransactionTemplate transactionTemplate;
     protected Consumer consumer;
-    protected Exchange receivedExchange;
-    protected CountDownLatch latch = new CountDownLatch(1);
+    protected volatile Exchange receivedExchange;
     protected String entityName = SendEmail.class.getName();
     protected String queryText = "select o from " + entityName + " o";
 
@@ -80,20 +79,19 @@ public void process(Exchange exchange) {
             public void process(Exchange e) {
                 LOG.info("Received exchange: {}", e.getIn());
                 receivedExchange = e;
-                // should have a EntityManager
-                EntityManager entityManager = e.getIn().getHeader(JpaConstants.ENTITY_MANAGER, EntityManager.class);
-                assertNotNull(entityManager, "Should have a EntityManager as header");
-                latch.countDown();
             }
         });
         consumer.start();
 
-        assertTrue(latch.await(50, TimeUnit.SECONDS));
-
-        assertNotNull(receivedExchange);
-        SendEmail result = receivedExchange.getIn().getBody(SendEmail.class);
-        assertNotNull(result, "Received a POJO");
-        assertEquals("foo@bar.com", result.getAddress(), "address property");
+        await().atMost(10, TimeUnit.SECONDS).untilAsserted(() -> {
+            assertNotNull(receivedExchange);
+            // should have a EntityManager
+            EntityManager em = receivedExchange.getIn().getHeader(JpaConstants.ENTITY_MANAGER, EntityManager.class);
+            assertNotNull(em, "Should have a EntityManager as header");
+            SendEmail result = receivedExchange.getIn().getBody(SendEmail.class);
+            assertNotNull(result, "Received a POJO");
+            assertEquals("foo@bar.com", result.getAddress(), "address property");
+        });
     }
 
     @Test

components/camel-jpa/src/test/java/org/apache/camel/component/jpa/JpaWithNamedQueryAndParametersTest.java

@@ -19,7 +19,6 @@
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
-import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.TimeUnit;
 
 import jakarta.persistence.EntityManager;
@@ -42,6 +41,7 @@
 import org.springframework.transaction.support.TransactionCallback;
 import org.springframework.transaction.support.TransactionTemplate;
 
+import static org.awaitility.Awaitility.await;
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertNotNull;
 import static org.junit.jupiter.api.Assertions.assertTrue;
@@ -56,8 +56,7 @@ public class JpaWithNamedQueryAndParametersTest {
     protected EntityManager entityManager;
     protected TransactionTemplate transactionTemplate;
     protected Consumer consumer;
-    protected Exchange receivedExchange;
-    protected CountDownLatch latch = new CountDownLatch(1);
+    protected volatile Exchange receivedExchange;
     protected String entityName = Customer.class.getName();
     protected String queryText = "select o from " + entityName + " o where o.name like 'Willem'";
 
@@ -99,14 +98,12 @@ public void process(Exchange exchange) {
             public void process(Exchange e) {
                 LOG.info("Received exchange: {}", e.getIn());
                 receivedExchange = e;
-                latch.countDown();
             }
         });
         consumer.start();
 
-        assertTrue(latch.await(10, TimeUnit.SECONDS));
-
-        assertReceivedResult(receivedExchange);
+        await().atMost(10, TimeUnit.SECONDS)
+                .untilAsserted(() -> assertReceivedResult(receivedExchange));
 
         JpaConsumer jpaConsumer = (JpaConsumer) consumer;
         assertURIQueryOption(jpaConsumer);

components/camel-jpa/src/test/java/org/apache/camel/component/jpa/JpaWithNamedQueryTest.java

@@ -17,7 +17,6 @@
 package org.apache.camel.component.jpa;
 
 import java.util.List;
-import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.TimeUnit;
 
 import jakarta.persistence.EntityManager;
@@ -57,8 +56,7 @@ public class JpaWithNamedQueryTest {
     protected EntityManager entityManager;
     protected TransactionTemplate transactionTemplate;
     protected Consumer consumer;
-    protected Exchange receivedExchange;
-    protected CountDownLatch latch = new CountDownLatch(1);
+    protected volatile Exchange receivedExchange;
     protected String entityName = MultiSteps.class.getName();
     protected String queryText = "select o from " + entityName + " o where o.step = 1";
 
@@ -100,14 +98,12 @@ public void process(Exchange e) {
                 LOG.info("Received exchange: {}", e.getIn());
                 // make defensive copy
                 receivedExchange = e.copy();
-                latch.countDown();
             }
         });
         consumer.start();
 
-        assertTrue(latch.await(10, TimeUnit.SECONDS));
-
-        assertReceivedResult(receivedExchange);
+        await().atMost(10, TimeUnit.SECONDS)
+                .untilAsserted(() -> assertReceivedResult(receivedExchange));
 
         // lets now test that the database is updated.
         // the consumer updates the row from within its own transaction, so we poll until that

components/camel-jpa/src/test/java/org/apache/camel/component/jpa/JpaWithNativeQueryTest.java

@@ -19,14 +19,11 @@
 import org.apache.camel.Exchange;
 import org.apache.camel.examples.MultiSteps;
 import org.junit.jupiter.api.Timeout;
-import org.junit.jupiter.api.condition.DisabledIfSystemProperty;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertNotNull;
 
 @Timeout(30)
-@DisabledIfSystemProperty(named = "ci.env.name", matches = ".*",
-                          disabledReason = "Apache CI is hanging on this test")
 public class JpaWithNativeQueryTest extends JpaWithNamedQueryTest {
 
     /**

components/camel-jpa/src/test/java/org/apache/camel/component/jpa/JpaWithNativeQueryWithResultClassTest.java

@@ -18,13 +18,12 @@
 
 import org.apache.camel.Exchange;
 import org.apache.camel.examples.MultiSteps;
-import org.junit.jupiter.api.condition.DisabledIfSystemProperty;
+import org.junit.jupiter.api.Timeout;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertNotNull;
 
-@DisabledIfSystemProperty(named = "ci.env.name", matches = ".*",
-                          disabledReason = "Apache CI is hanging on this test")
+@Timeout(30)
 public class JpaWithNativeQueryWithResultClassTest extends JpaWithNamedQueryTest {
 
     /**

components/camel-jpa/src/test/java/org/apache/camel/component/jpa/JpaWithQueryTest.java

@@ -18,13 +18,10 @@
 
 import org.apache.camel.examples.MultiSteps;
 import org.junit.jupiter.api.Timeout;
-import org.junit.jupiter.api.condition.DisabledIfSystemProperty;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
 
 @Timeout(30)
-@DisabledIfSystemProperty(named = "ci.env.name", matches = ".*",
-                          disabledReason = "Apache CI is hanging on this test")
 public class JpaWithQueryTest extends JpaWithNamedQueryTest {
 
     @Override