(camel) branch main updated: chore: stabilize MulticastParallelStreamingTest.testMulticastParallel() (#16054)

[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 8dce1b82054 chore: stabilize 
MulticastParallelStreamingTest.testMulticastParallel() (#16054)
8dce1b82054 is described below

commit 8dce1b8205470c5fbdc341e6668888fdbc847cf9
Author: Aurélien Pupier <apup...@redhat.com>
AuthorDate: Wed Oct 23 10:44:31 2024 +0200

    chore: stabilize MulticastParallelStreamingTest.testMulticastParallel() 
(#16054)
    
    The test is flaky on CI.
    Locally, I was able to have it flaky locally with a delay of 3
    milliseconds (1 failure out of 100). It was previously 250 milliseconds
    delay. it seems to not be always enough on Jenkins CI. Which is a bit
    weird as it is quite huge gap.
    Trying with a more important delay.
    The order of received message is only based on this delay but if the
    second route is not executing in this delay, the test is failing. There
    is no other controls on that, there is no guarantee at Camel level to
    respect a specific order.
    
    Signed-off-by: Aurélien Pupier <apup...@redhat.com>
---
 .../java/org/apache/camel/processor/MulticastParallelStreamingTest.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/core/camel-core/src/test/java/org/apache/camel/processor/MulticastParallelStreamingTest.java
 
b/core/camel-core/src/test/java/org/apache/camel/processor/MulticastParallelStreamingTest.java
index 1efd34fbf03..e2ab132d2aa 100644
--- 
a/core/camel-core/src/test/java/org/apache/camel/processor/MulticastParallelStreamingTest.java
+++ 
b/core/camel-core/src/test/java/org/apache/camel/processor/MulticastParallelStreamingTest.java
@@ -75,7 +75,7 @@ public class MulticastParallelStreamingTest extends 
ContextTestSupport {
                         // use end to indicate end of multicast route
                         .end().to("mock:result");
 
-                
from("direct:a").delay(250).asyncDelayed().setBody(constant("A"));
+                
from("direct:a").delay(500).asyncDelayed().setBody(constant("A"));
 
                 from("direct:b").setBody(constant("B"));
             }