[camel] branch camel-3.11.x updated: CAMEL-16893: Prevent potential NPE in shutdown of GrpcStreamingExchangeForwarder

[jamesnetherton]

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 <jamesnether...@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();
     }