You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ja...@apache.org on 2021/08/31 09:39:42 UTC
[camel] branch camel-3.11.x updated: CAMEL-16893: Prevent potential
NPE in shutdown of GrpcStreamingExchangeForwarder
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a commit to branch camel-3.11.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-3.11.x by this push:
new 6f25d5c CAMEL-16893: Prevent potential NPE in shutdown of GrpcStreamingExchangeForwarder
6f25d5c is described below
commit 6f25d5c3c0d34a24baa5339a45a38e4652362e27
Author: James Netherton <ja...@gmail.com>
AuthorDate: Tue Aug 31 08:39:54 2021 +0100
CAMEL-16893: Prevent potential NPE in shutdown of GrpcStreamingExchangeForwarder
---
.../camel/component/grpc/client/GrpcStreamingExchangeForwarder.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/components/camel-grpc/src/main/java/org/apache/camel/component/grpc/client/GrpcStreamingExchangeForwarder.java b/components/camel-grpc/src/main/java/org/apache/camel/component/grpc/client/GrpcStreamingExchangeForwarder.java
index 0afbda4..eb3c284 100644
--- a/components/camel-grpc/src/main/java/org/apache/camel/component/grpc/client/GrpcStreamingExchangeForwarder.java
+++ b/components/camel-grpc/src/main/java/org/apache/camel/component/grpc/client/GrpcStreamingExchangeForwarder.java
@@ -56,7 +56,9 @@ class GrpcStreamingExchangeForwarder implements GrpcExchangeForwarder {
@Override
public void shutdown() {
- checkAndRecreateStreamObserver(this.currentResponseObserver).onCompleted();
+ if (this.currentResponseObserver != null) {
+ checkAndRecreateStreamObserver(this.currentResponseObserver).onCompleted();
+ }
doCloseStream();
}