(camel) 05/06: CAMEL-20297 camel-stream: 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 de350b2ac2814314f1786b47011824326181fb89
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Fri Jan 5 11:20:31 2024 +0100

    CAMEL-20297 camel-stream: do not swallow interrupted exceptions
---
 .../main/java/org/apache/camel/component/stream/StreamProducer.java    | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamProducer.java
 
b/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamProducer.java
index 70bb0d48708..77b0e7d5298 100644
--- 
a/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamProducer.java
+++ 
b/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamProducer.java
@@ -78,6 +78,9 @@ public class StreamProducer extends DefaultAsyncProducer {
                     closeStream(exchange, false);
                 }
             }
+        } catch (InterruptedException e) {
+            exchange.setException(e);
+            Thread.currentThread().interrupt();
         } catch (Exception e) {
             exchange.setException(e);
         }