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 <[email protected]> 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); }
