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

Reply via email to