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 642ddcfac3ac07052d5612d5274af3523507a422
Author: Otavio Rodolfo Piske <[email protected]>
AuthorDate: Mon Jan 15 11:06:14 2024 +0100

    CAMEL-20297 camel-platform-http-vertx: do not swallow interrupted exceptions
---
 .../camel/component/platform/http/vertx/VertxPlatformHttpServer.java   | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/components/camel-platform-http-vertx/src/main/java/org/apache/camel/component/platform/http/vertx/VertxPlatformHttpServer.java
 
b/components/camel-platform-http-vertx/src/main/java/org/apache/camel/component/platform/http/vertx/VertxPlatformHttpServer.java
index 132c3c6139a..8eed4dd9467 100644
--- 
a/components/camel-platform-http-vertx/src/main/java/org/apache/camel/component/platform/http/vertx/VertxPlatformHttpServer.java
+++ 
b/components/camel-platform-http-vertx/src/main/java/org/apache/camel/component/platform/http/vertx/VertxPlatformHttpServer.java
@@ -232,6 +232,7 @@ public class VertxPlatformHttpServer extends ServiceSupport 
implements CamelCont
                     try {
                         latch.await();
                     } catch (InterruptedException e) {
+                        Thread.currentThread().interrupt();
                         throw new RuntimeException(e);
                     }
                 },
@@ -269,6 +270,7 @@ public class VertxPlatformHttpServer extends ServiceSupport 
implements CamelCont
                         try {
                             latch.await();
                         } catch (InterruptedException e) {
+                            Thread.currentThread().interrupt();
                             throw new RuntimeException(e);
                         }
                     },
@@ -306,6 +308,7 @@ public class VertxPlatformHttpServer extends ServiceSupport 
implements CamelCont
                         try {
                             latch.await();
                         } catch (InterruptedException e) {
+                            Thread.currentThread().interrupt();
                             throw new RuntimeException(e);
                         }
                     },

Reply via email to