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

Reply via email to