You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2024/01/15 13:21:07 UTC
(camel) 07/10: CAMEL-20297 camel-olingo4: do not swallow interrupted exceptions
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 8b11504c44912d5cc43c4043271421b520734129
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Mon Jan 15 11:05:48 2024 +0100
CAMEL-20297 camel-olingo4: do not swallow interrupted exceptions
---
.../java/org/apache/camel/component/olingo4/Olingo4AppWrapper.java | 1 +
.../main/java/org/apache/camel/component/olingo4/Olingo4Consumer.java | 4 +++-
2 files changed, 4 insertions(+), 1 deletion(-)
diff --git a/components/camel-olingo4/camel-olingo4-component/src/main/java/org/apache/camel/component/olingo4/Olingo4AppWrapper.java b/components/camel-olingo4/camel-olingo4-component/src/main/java/org/apache/camel/component/olingo4/Olingo4AppWrapper.java
index fd70ef9d270..f65f025357a 100644
--- a/components/camel-olingo4/camel-olingo4-component/src/main/java/org/apache/camel/component/olingo4/Olingo4AppWrapper.java
+++ b/components/camel-olingo4/camel-olingo4-component/src/main/java/org/apache/camel/component/olingo4/Olingo4AppWrapper.java
@@ -96,6 +96,7 @@ public class Olingo4AppWrapper {
}
} catch (InterruptedException e) {
+ Thread.currentThread().interrupt();
throw new RuntimeCamelException(e.getMessage(), e);
}
diff --git a/components/camel-olingo4/camel-olingo4-component/src/main/java/org/apache/camel/component/olingo4/Olingo4Consumer.java b/components/camel-olingo4/camel-olingo4-component/src/main/java/org/apache/camel/component/olingo4/Olingo4Consumer.java
index 1f44e43dab1..957a155a882 100644
--- a/components/camel-olingo4/camel-olingo4-component/src/main/java/org/apache/camel/component/olingo4/Olingo4Consumer.java
+++ b/components/camel-olingo4/camel-olingo4-component/src/main/java/org/apache/camel/component/olingo4/Olingo4Consumer.java
@@ -106,7 +106,9 @@ public class Olingo4Consumer extends AbstractApiConsumer<Olingo4ApiName, Olingo4
} else {
return ApiConsumerHelper.getResultsProcessed(this, result[0], isSplitResult());
}
-
+ } catch (InterruptedException e) {
+ Thread.currentThread().interrupt();
+ throw RuntimeCamelException.wrapRuntimeCamelException(e);
} catch (Exception e) {
throw RuntimeCamelException.wrapRuntimeCamelException(e);
}