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
The following commit(s) were added to refs/heads/main by this push: new 36c0a9126b1 CAMEL-20225: adjust DefaultRoute to use the StopWatch (#12511) 36c0a9126b1 is described below commit 36c0a9126b1aa4d75edeb0bb4949310bc3c17376 Author: Otavio Rodolfo Piske <orpi...@users.noreply.github.com> AuthorDate: Wed Dec 20 14:45:33 2023 -0300 CAMEL-20225: adjust DefaultRoute to use the StopWatch (#12511) --- .../main/java/org/apache/camel/impl/engine/DefaultRoute.java | 12 +++++------- .../src/main/java/org/apache/camel/util/StopWatch.java | 7 +++++++ 2 files changed, 12 insertions(+), 7 deletions(-) diff --git a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultRoute.java b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultRoute.java index d8ace10e795..7263f3df44a 100644 --- a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultRoute.java +++ b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultRoute.java @@ -59,6 +59,7 @@ import org.apache.camel.support.resume.AdapterHelper; import org.apache.camel.support.service.ServiceHelper; import org.apache.camel.support.service.ServiceSupport; import org.apache.camel.util.ObjectHelper; +import org.apache.camel.util.StopWatch; import org.apache.camel.util.TimeUtils; /** @@ -106,7 +107,7 @@ public class DefaultRoute extends ServiceSupport implements Route { private final Endpoint endpoint; private final Map<String, Object> properties = new HashMap<>(); private final List<Service> services = new ArrayList<>(); - private long startDate; + private StopWatch stopWatch = new StopWatch(false); private RouteError routeError; private Integer startupOrder; private RouteController routeController; @@ -156,10 +157,7 @@ public class DefaultRoute extends ServiceSupport implements Route { @Override public long getUptimeMillis() { - if (startDate == 0) { - return 0; - } - return System.currentTimeMillis() - startDate; + return stopWatch.taken(); } @Override @@ -247,13 +245,13 @@ public class DefaultRoute extends ServiceSupport implements Route { @Override protected void doStart() throws Exception { - startDate = System.currentTimeMillis(); + stopWatch.restart(); } @Override protected void doStop() throws Exception { // and clear start date - startDate = 0; + stopWatch.stop(); } @Override diff --git a/core/camel-util/src/main/java/org/apache/camel/util/StopWatch.java b/core/camel-util/src/main/java/org/apache/camel/util/StopWatch.java index a4b3945f61a..be49ceeba71 100644 --- a/core/camel-util/src/main/java/org/apache/camel/util/StopWatch.java +++ b/core/camel-util/src/main/java/org/apache/camel/util/StopWatch.java @@ -83,4 +83,11 @@ public final class StopWatch { return answer; } + /** + * Stops the stop watch + */ + public void stop() { + start = 0; + } + }