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

Croway 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 05ac29de8017 CAMEL-25220: camel-quartz - Fix flaky 
SpringQuartzConsumerTwoAppsClusteredRecoveryTest
05ac29de8017 is described below

commit 05ac29de8017fffc123d7f4f5bb019c636ab4df7
Author: Urmila Unni <[email protected]>
AuthorDate: Thu Oct 8 21:19:09 2026 +0530

    CAMEL-25220: camel-quartz - Fix flaky 
SpringQuartzConsumerTwoAppsClusteredRecoveryTest
    
    Allow 30s for the cluster recovery instead of Awaitility's 10s default.
    
    Co-authored-by: Claude <[email protected]>
---
 .../quartz/SpringQuartzConsumerTwoAppsClusteredRecoveryTest.java   | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git 
a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/SpringQuartzConsumerTwoAppsClusteredRecoveryTest.java
 
b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/SpringQuartzConsumerTwoAppsClusteredRecoveryTest.java
index 9296f2d6a075..98c6464a03ef 100644
--- 
a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/SpringQuartzConsumerTwoAppsClusteredRecoveryTest.java
+++ 
b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/SpringQuartzConsumerTwoAppsClusteredRecoveryTest.java
@@ -16,6 +16,8 @@
  */
 package org.apache.camel.component.quartz;
 
+import java.util.concurrent.TimeUnit;
+
 import org.apache.camel.CamelContext;
 import org.apache.camel.Exchange;
 import org.apache.camel.Predicate;
@@ -62,8 +64,9 @@ public class SpringQuartzConsumerTwoAppsClusteredRecoveryTest 
{
         AbstractXmlApplicationContext app2 = 
newAppContext("SpringQuartzConsumerRecoveryClusteredAppTwo.xml");
         app2.start();
 
-        // wait long enough until the second app takes it over...
-        Awaitility.await().untilAsserted(() -> {
+        // Quartz only declares app-one failed after its check-in interval 
plus a fixed 7.5s grace period, so the
+        // recovery alone takes most of Awaitility's 10s default; allow enough 
time on a loaded CI machine
+        Awaitility.await().atMost(30, TimeUnit.SECONDS).untilAsserted(() -> {
             CamelContext camel2 = app2.getBean("camelContext2-" + 
getClass().getSimpleName(), CamelContext.class);
 
             MockEndpoint mock2 = camel2.getEndpoint("mock:result", 
MockEndpoint.class);

Reply via email to