[camel] branch main 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 main
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/main by this push:
     new 5d2c4dc  CAMEL-16893: Prevent potential NPE in shutdown of 
GrpcStreamingExchangeForwarder
5d2c4dc is described below

commit 5d2c4dce9cb605577d1df6a814fde58b6f5d271f
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();
     }