You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2017/04/27 14:38:10 UTC
camel git commit: CAMEL-11213: camel-grpc doesn't terminate channel
when producer stops
Repository: camel
Updated Branches:
refs/heads/master 2be04c739 -> 0cbe346bd
CAMEL-11213: camel-grpc doesn't terminate channel when producer stops
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/0cbe346b
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/0cbe346b
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/0cbe346b
Branch: refs/heads/master
Commit: 0cbe346bd570537aae37cc5ee82acedb84e19168
Parents: 2be04c7
Author: Dmitry Volodin <dm...@gmail.com>
Authored: Thu Apr 27 17:28:00 2017 +0300
Committer: Claus Ibsen <da...@apache.org>
Committed: Thu Apr 27 16:37:26 2017 +0200
----------------------------------------------------------------------
.../main/java/org/apache/camel/component/grpc/GrpcProducer.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/0cbe346b/components/camel-grpc/src/main/java/org/apache/camel/component/grpc/GrpcProducer.java
----------------------------------------------------------------------
diff --git a/components/camel-grpc/src/main/java/org/apache/camel/component/grpc/GrpcProducer.java b/components/camel-grpc/src/main/java/org/apache/camel/component/grpc/GrpcProducer.java
index 232b8d7..8018802 100644
--- a/components/camel-grpc/src/main/java/org/apache/camel/component/grpc/GrpcProducer.java
+++ b/components/camel-grpc/src/main/java/org/apache/camel/component/grpc/GrpcProducer.java
@@ -112,8 +112,8 @@ public class GrpcProducer extends DefaultProducer implements AsyncProcessor {
@Override
protected void doStop() throws Exception {
- if (channel == null) {
- LOG.trace("Terminating channel to the remote gRPC server " + channel);
+ if (channel != null) {
+ LOG.trace("Terminating channel to the remote gRPC server");
channel.shutdown().shutdownNow();
channel = null;
grpcStub = null;