[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 4e5a0f26929 Fix flaky test
4e5a0f26929 is described below

commit 4e5a0f26929b2376a52ed8684cf29720604afde7
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Fri Aug 25 07:41:30 2023 +0200

    Fix flaky test
---
 .../apache/camel/processor/ConsumerRouteIdAwareTest.java  | 15 ++++++++-------
 1 file changed, 8 insertions(+), 7 deletions(-)

diff --git 
a/core/camel-core/src/test/java/org/apache/camel/processor/ConsumerRouteIdAwareTest.java
 
b/core/camel-core/src/test/java/org/apache/camel/processor/ConsumerRouteIdAwareTest.java
index 21429a21f7f..6af94be6e0d 100644
--- 
a/core/camel-core/src/test/java/org/apache/camel/processor/ConsumerRouteIdAwareTest.java
+++ 
b/core/camel-core/src/test/java/org/apache/camel/processor/ConsumerRouteIdAwareTest.java
@@ -31,9 +31,7 @@ import org.apache.camel.support.DefaultComponent;
 import org.apache.camel.support.DefaultConsumer;
 import org.apache.camel.support.DefaultEndpoint;
 import org.junit.jupiter.api.Test;
-import org.junit.jupiter.api.parallel.Isolated;
 
-@Isolated
 public class ConsumerRouteIdAwareTest extends ContextTestSupport {
 
     @Override
@@ -88,21 +86,24 @@ public class ConsumerRouteIdAwareTest extends 
ContextTestSupport {
 
         public MyConsumer(Endpoint endpoint, Processor processor) {
             super(endpoint, processor);
+        }
+
+        @Override
+        protected void doStart() throws Exception {
+            super.doStart();
 
             Runnable run = () -> {
-                Exchange exchange = endpoint.createExchange();
+                Exchange exchange = getEndpoint().createExchange();
                 exchange.getMessage().setBody("Hello from consumer route " + 
getRouteId());
                 try {
-                    Thread.sleep(100);
-                    processor.process(exchange);
+                    getProcessor().process(exchange);
                 } catch (Exception e) {
-                    // ignore
+                    exchange.setException(e);
                 }
             };
             Thread t = new Thread(run);
             t.start();
         }
-
     }
 
 }