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/08 16:10:27 UTC
(camel) 05/06: CAMEL-20297 camel-stream: 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 de350b2ac2814314f1786b47011824326181fb89
Author: Otavio Rodolfo Piske <an...@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);
}