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
commit 29d5f1c19e19dbd85ae2d57f9dff9136ac0c82ba Author: Claus Ibsen <[email protected]> AuthorDate: Thu Sep 1 10:03:07 2022 +0200 Polished --- .../impl/engine/DefaultSupervisingRouteController.java | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultSupervisingRouteController.java b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultSupervisingRouteController.java index 545a39c6bc4..19bb2e8cb00 100644 --- a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultSupervisingRouteController.java +++ b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultSupervisingRouteController.java @@ -242,7 +242,7 @@ public class DefaultSupervisingRouteController extends DefaultRouteController im public void startRoute(String routeId) throws Exception { final Optional<RouteHolder> route = routes.stream().filter(r -> r.getId().equals(routeId)).findFirst(); - if (!route.isPresent()) { + if (route.isEmpty()) { // This route is unknown to this controller, apply default behaviour // from super class. super.startRoute(routeId); @@ -255,7 +255,7 @@ public class DefaultSupervisingRouteController extends DefaultRouteController im public void stopRoute(String routeId) throws Exception { final Optional<RouteHolder> route = routes.stream().filter(r -> r.getId().equals(routeId)).findFirst(); - if (!route.isPresent()) { + if (route.isEmpty()) { // This route is unknown to this controller, apply default behaviour // from super class. super.stopRoute(routeId); @@ -268,7 +268,7 @@ public class DefaultSupervisingRouteController extends DefaultRouteController im public void stopRoute(String routeId, Throwable cause) throws Exception { final Optional<RouteHolder> route = routes.stream().filter(r -> r.getId().equals(routeId)).findFirst(); - if (!route.isPresent()) { + if (route.isEmpty()) { // This route is unknown to this controller, apply default behaviour // from super class. super.stopRoute(routeId, cause); @@ -281,7 +281,7 @@ public class DefaultSupervisingRouteController extends DefaultRouteController im public void stopRoute(String routeId, long timeout, TimeUnit timeUnit) throws Exception { final Optional<RouteHolder> route = routes.stream().filter(r -> r.getId().equals(routeId)).findFirst(); - if (!route.isPresent()) { + if (route.isEmpty()) { // This route is unknown to this controller, apply default behaviour // from super class. super.stopRoute(routeId, timeout, timeUnit); @@ -310,7 +310,7 @@ public class DefaultSupervisingRouteController extends DefaultRouteController im public void suspendRoute(String routeId) throws Exception { final Optional<RouteHolder> route = routes.stream().filter(r -> r.getId().equals(routeId)).findFirst(); - if (!route.isPresent()) { + if (route.isEmpty()) { // This route is unknown to this controller, apply default behaviour // from super class. super.suspendRoute(routeId); @@ -323,7 +323,7 @@ public class DefaultSupervisingRouteController extends DefaultRouteController im public void suspendRoute(String routeId, long timeout, TimeUnit timeUnit) throws Exception { final Optional<RouteHolder> route = routes.stream().filter(r -> r.getId().equals(routeId)).findFirst(); - if (!route.isPresent()) { + if (route.isEmpty()) { // This route is unknown to this controller, apply default behaviour // from super class. super.suspendRoute(routeId, timeout, timeUnit); @@ -336,7 +336,7 @@ public class DefaultSupervisingRouteController extends DefaultRouteController im public void resumeRoute(String routeId) throws Exception { final Optional<RouteHolder> route = routes.stream().filter(r -> r.getId().equals(routeId)).findFirst(); - if (!route.isPresent()) { + if (route.isEmpty()) { // This route is unknown to this controller, apply default behaviour // from super class. super.resumeRoute(routeId);
