This is an automated email from the ASF dual-hosted git repository. orpiske pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit 6244f305876ca0d67fd82eda78793177e1e5c296 Author: Otavio Rodolfo Piske <angusyo...@gmail.com> AuthorDate: Mon Apr 29 10:45:12 2024 +0200 (chores) camel-controlbus: minor test cleanup --- .../apache/camel/component/controlbus/ControlBusFailRouteTest.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/core/camel-core/src/test/java/org/apache/camel/component/controlbus/ControlBusFailRouteTest.java b/core/camel-core/src/test/java/org/apache/camel/component/controlbus/ControlBusFailRouteTest.java index a6feecfab14..9034d748a35 100644 --- a/core/camel-core/src/test/java/org/apache/camel/component/controlbus/ControlBusFailRouteTest.java +++ b/core/camel-core/src/test/java/org/apache/camel/component/controlbus/ControlBusFailRouteTest.java @@ -21,6 +21,7 @@ import java.util.concurrent.TimeUnit; import org.apache.camel.ContextTestSupport; import org.apache.camel.Route; import org.apache.camel.builder.RouteBuilder; +import org.apache.camel.spi.RouteController; import org.apache.camel.spi.RouteError; import org.junit.jupiter.api.Assertions; import org.junit.jupiter.api.Test; @@ -32,12 +33,13 @@ public class ControlBusFailRouteTest extends ContextTestSupport { @Test public void testControlBusFail() { - assertEquals("Started", context.getRouteController().getRouteStatus("foo").name()); + final RouteController routeController = context.getRouteController(); + assertEquals("Started", routeController.getRouteStatus("foo").name()); template.sendBody("direct:foo", "Hello World"); // runs async so it can take a little while - await().atMost(5, TimeUnit.SECONDS).until(() -> context.getRouteController().getRouteStatus("foo").isStopped()); + await().atMost(5, TimeUnit.SECONDS).until(() -> routeController.getRouteStatus("foo").isStopped()); Route route = context.getRoute("foo"); RouteError re = route.getLastError();