(camel) 06/10: CAMEL-20297 camel-olingo2: do not swallow interrupted exceptions

[orpiske]

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 7b4e8d993dcb5405919d678c20e9abd710ea7be1
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Mon Jan 15 11:05:40 2024 +0100

    CAMEL-20297 camel-olingo2: do not swallow interrupted exceptions
---
 .../java/org/apache/camel/component/olingo2/Olingo2AppWrapper.java    | 1 +
 .../main/java/org/apache/camel/component/olingo2/Olingo2Consumer.java | 4 +++-
 2 files changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/components/camel-olingo2/camel-olingo2-component/src/main/java/org/apache/camel/component/olingo2/Olingo2AppWrapper.java
 
b/components/camel-olingo2/camel-olingo2-component/src/main/java/org/apache/camel/component/olingo2/Olingo2AppWrapper.java
index 04b233523c1..53f9a0e35fe 100644
--- 
a/components/camel-olingo2/camel-olingo2-component/src/main/java/org/apache/camel/component/olingo2/Olingo2AppWrapper.java
+++ 
b/components/camel-olingo2/camel-olingo2-component/src/main/java/org/apache/camel/component/olingo2/Olingo2AppWrapper.java
@@ -95,6 +95,7 @@ public class Olingo2AppWrapper {
                         }
 
                     } catch (InterruptedException e) {
+                        Thread.currentThread().interrupt();
                         throw new RuntimeCamelException(e.getMessage(), e);
                     }
 
diff --git 
a/components/camel-olingo2/camel-olingo2-component/src/main/java/org/apache/camel/component/olingo2/Olingo2Consumer.java
 
b/components/camel-olingo2/camel-olingo2-component/src/main/java/org/apache/camel/component/olingo2/Olingo2Consumer.java
index b81fc5df9da..a6e2f191da7 100644
--- 
a/components/camel-olingo2/camel-olingo2-component/src/main/java/org/apache/camel/component/olingo2/Olingo2Consumer.java
+++ 
b/components/camel-olingo2/camel-olingo2-component/src/main/java/org/apache/camel/component/olingo2/Olingo2Consumer.java
@@ -101,7 +101,9 @@ public class Olingo2Consumer extends 
AbstractApiConsumer<Olingo2ApiName, Olingo2
             } else {
                 return ApiConsumerHelper.getResultsProcessed(this, result[0], 
isSplitResult());
             }
-
+        } catch (InterruptedException e) {
+            Thread.currentThread().interrupt();
+            throw RuntimeCamelException.wrapRuntimeCamelException(e);
         } catch (Exception t) {
             throw RuntimeCamelException.wrapRuntimeCamelException(t);
         }