(camel) branch main updated: CAMEL-20225: adjust DefaultAsyncProcessorAwaitManager to use the StopWatch (#12509)

[or...@apache.org]

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 <or...@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