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 2020/10/12 07:03:23 UTC
[camel] branch camel-3.4.x updated: CAMEL-15669: Fixed camel-cloud
may hang if service registry is empty during service call EIP.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-3.4.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-3.4.x by this push:
new d95161d CAMEL-15669: Fixed camel-cloud may hang if service registry is empty during service call EIP.
d95161d is described below
commit d95161d550c8bac220d96d5c535cd375570dfe8f
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Mon Oct 12 09:02:33 2020 +0200
CAMEL-15669: Fixed camel-cloud may hang if service registry is empty during service call EIP.
---
.../java/org/apache/camel/impl/cloud/DefaultServiceCallProcessor.java | 1 +
1 file changed, 1 insertion(+)
diff --git a/core/camel-cloud/src/main/java/org/apache/camel/impl/cloud/DefaultServiceCallProcessor.java b/core/camel-cloud/src/main/java/org/apache/camel/impl/cloud/DefaultServiceCallProcessor.java
index a0b2d4c..4650a8b 100644
--- a/core/camel-cloud/src/main/java/org/apache/camel/impl/cloud/DefaultServiceCallProcessor.java
+++ b/core/camel-cloud/src/main/java/org/apache/camel/impl/cloud/DefaultServiceCallProcessor.java
@@ -176,6 +176,7 @@ public class DefaultServiceCallProcessor extends AsyncProcessorSupport {
return loadBalancer.process(serviceName, server -> execute(server, exchange, callback));
} catch (Exception e) {
exchange.setException(e);
+ callback.done(true);
return true;
}
}