(camel) 04/07: CAMEL-20297 camel-grpc: 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 8623fa384e4fa0c9b189dae3798c2aee4e269fc0
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Thu Jan 11 10:11:03 2024 +0100

    CAMEL-20297 camel-grpc: do not swallow interrupted exceptions
---
 .../component/grpc/server/GrpcRequestAggregationStreamObserver.java     | 1 +
 .../component/grpc/server/GrpcRequestPropagationStreamObserver.java     | 2 ++
 2 files changed, 3 insertions(+)

diff --git 
a/components/camel-grpc/src/main/java/org/apache/camel/component/grpc/server/GrpcRequestAggregationStreamObserver.java
 
b/components/camel-grpc/src/main/java/org/apache/camel/component/grpc/server/GrpcRequestAggregationStreamObserver.java
index e7dcea253f4..d0aa4b2b197 100644
--- 
a/components/camel-grpc/src/main/java/org/apache/camel/component/grpc/server/GrpcRequestAggregationStreamObserver.java
+++ 
b/components/camel-grpc/src/main/java/org/apache/camel/component/grpc/server/GrpcRequestAggregationStreamObserver.java
@@ -71,6 +71,7 @@ public class GrpcRequestAggregationStreamObserver extends 
GrpcRequestAbstractStr
             }
             responseObserver.onCompleted();
         } catch (InterruptedException e) {
+            Thread.currentThread().interrupt();
             responseObserver.onError(e);
         }
     }
diff --git 
a/components/camel-grpc/src/main/java/org/apache/camel/component/grpc/server/GrpcRequestPropagationStreamObserver.java
 
b/components/camel-grpc/src/main/java/org/apache/camel/component/grpc/server/GrpcRequestPropagationStreamObserver.java
index 091b120eb22..4764cceac0b 100644
--- 
a/components/camel-grpc/src/main/java/org/apache/camel/component/grpc/server/GrpcRequestPropagationStreamObserver.java
+++ 
b/components/camel-grpc/src/main/java/org/apache/camel/component/grpc/server/GrpcRequestPropagationStreamObserver.java
@@ -56,7 +56,9 @@ public class GrpcRequestPropagationStreamObserver extends 
GrpcRequestAbstractStr
                 responseObserver.onNext(responseBody);
             }
         } catch (InterruptedException e) {
+            Thread.currentThread().interrupt();
             responseObserver.onError(e);
+
         }
     }