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;
         }
     }