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 3b4cd72e727639eee0fed3ecd2222891b31fe80c Author: Otavio Rodolfo Piske <angusyo...@gmail.com> AuthorDate: Thu Feb 22 17:49:05 2024 +0100 CAMEL-20014: stop using the deprecated getStartupStepRecorder method Adjust the code to use the getStartupStepRecorder from the extension. --- .../camel/impl/engine/InternalRouteStartupManager.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/InternalRouteStartupManager.java b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/InternalRouteStartupManager.java index 2a8e9839f3d..d6da72b40a4 100644 --- a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/InternalRouteStartupManager.java +++ b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/InternalRouteStartupManager.java @@ -77,7 +77,7 @@ final class InternalRouteStartupManager { camelContext.setStartingRoutes(true); try { for (RouteService routeService : routeServices.values()) { - StartupStep step = camelContext.getStartupStepRecorder().beginStep(Route.class, routeService.getId(), + StartupStep step = camelContext.getCamelContextExtension().getStartupStepRecorder().beginStep(Route.class, routeService.getId(), "Init Route"); try { LOG.debug("Initializing route id: {}", routeService.getId()); @@ -88,7 +88,7 @@ final class InternalRouteStartupManager { routeService.setUp(); } finally { setupRoute.remove(); - camelContext.getStartupStepRecorder().endStep(step); + camelContext.getCamelContextExtension().getStartupStepRecorder().endStep(step); } } } finally { @@ -298,7 +298,7 @@ final class InternalRouteStartupManager { // will then be prepared in time before we start inputs which will // consume messages to be routed RouteService routeService = entry.getValue().getRouteService(); - StartupStep step = camelContext.getStartupStepRecorder().beginStep(Route.class, routeService.getId(), + StartupStep step = camelContext.getCamelContextExtension().getStartupStepRecorder().beginStep(Route.class, routeService.getId(), "Warump Route"); try { LOG.debug("Warming up route id: {} having autoStartup={}", routeService.getId(), autoStartup); @@ -308,7 +308,7 @@ final class InternalRouteStartupManager { routeService.warmUp(); } finally { setupRoute.remove(); - camelContext.getStartupStepRecorder().endStep(step); + camelContext.getCamelContextExtension().getStartupStepRecorder().endStep(step); } } } @@ -350,7 +350,7 @@ final class InternalRouteStartupManager { continue; } - StartupStep step = camelContext.getStartupStepRecorder().beginStep(Route.class, route.getRouteId(), + StartupStep step = camelContext.getCamelContextExtension().getStartupStepRecorder().beginStep(Route.class, route.getRouteId(), "Start Route"); // do some preparation before starting the consumer on the route @@ -451,7 +451,7 @@ final class InternalRouteStartupManager { } } - camelContext.getStartupStepRecorder().endStep(step); + camelContext.getCamelContextExtension().getStartupStepRecorder().endStep(step); } }