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/11 17:49:32 UTC
camel git commit: camel-grpc: hangs on async invocation with
exception (missed callback.done)
Repository: camel
Updated Branches:
refs/heads/master 3bf99ccaf -> 3b977b01c
camel-grpc: hangs on async invocation with exception (missed
callback.done)
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/3b977b01
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/3b977b01
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/3b977b01
Branch: refs/heads/master
Commit: 3b977b01c914e76a65e1ad10bf4597deeecf0b35
Parents: 3bf99cc
Author: Dmitry Volodin <dm...@gmail.com>
Authored: Tue Apr 11 19:28:34 2017 +0300
Committer: Dmitry Volodin <dm...@gmail.com>
Committed: Tue Apr 11 19:28:34 2017 +0300
----------------------------------------------------------------------
.../main/java/org/apache/camel/component/grpc/GrpcProducer.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/3b977b01/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 ec07022..10d8faf 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
@@ -69,7 +69,7 @@ public class GrpcProducer extends DefaultProducer implements AsyncProcessor {
@Override
public void onError(Throwable t) {
exchange.setException(t);
- callback.done(true);
+ callback.done(false);
}
@Override
@@ -82,6 +82,7 @@ public class GrpcProducer extends DefaultProducer implements AsyncProcessor {
GrpcUtils.invokeAsyncMethod(grpcStub, configuration.getMethod(), message.getBody(), asyncHandler);
} catch (Exception e) {
exchange.setException(e);
+ callback.done(true);
return true;
}
return false;