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(); } - } }