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 b61c06a5583 CAMEL-20225: adjust DefaultAsyncProcessorAwaitManager to use the StopWatch (#12509) b61c06a5583 is described below commit b61c06a558329a2e3a590c111a43d5500708c3b7 Author: Otavio Rodolfo Piske <orpi...@users.noreply.github.com> AuthorDate: Wed Dec 20 13:38:03 2023 -0300 CAMEL-20225: adjust DefaultAsyncProcessorAwaitManager to use the StopWatch (#12509) --- .../apache/camel/impl/engine/DefaultAsyncProcessorAwaitManager.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultAsyncProcessorAwaitManager.java b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultAsyncProcessorAwaitManager.java index 719cb881325..650701f42a1 100644 --- a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultAsyncProcessorAwaitManager.java +++ b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultAsyncProcessorAwaitManager.java @@ -35,6 +35,7 @@ import org.apache.camel.support.ExchangeHelper; import org.apache.camel.support.MessageHelper; import org.apache.camel.support.processor.DefaultExchangeFormatter; import org.apache.camel.support.service.ServiceSupport; +import org.apache.camel.util.StopWatch; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -279,13 +280,12 @@ public class DefaultAsyncProcessorAwaitManager extends ServiceSupport implements private final Thread thread; private final Exchange exchange; private final CountDownLatch latch; - private final long start; + private final StopWatch watch = new StopWatch(); private AwaitThreadEntry(Thread thread, Exchange exchange, CountDownLatch latch) { this.thread = thread; this.exchange = exchange; this.latch = latch; - this.start = System.currentTimeMillis(); } @Override @@ -300,7 +300,7 @@ public class DefaultAsyncProcessorAwaitManager extends ServiceSupport implements @Override public long getWaitDuration() { - return System.currentTimeMillis() - start; + return watch.taken(); } @Override