This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
commit c6e82083ea76aec3fac42133394ac71335ad0659 Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Sat Jun 9 14:14:10 2018 +0200 Fixed CS --- .../main/java/org/apache/camel/impl/saga/InMemorySagaCoordinator.java | 4 +++- .../src/main/java/org/apache/camel/processor/saga/SagaProcessor.java | 3 ++- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/camel-core/src/main/java/org/apache/camel/impl/saga/InMemorySagaCoordinator.java b/camel-core/src/main/java/org/apache/camel/impl/saga/InMemorySagaCoordinator.java index 1d3f44e..1cb8ac4 100644 --- a/camel-core/src/main/java/org/apache/camel/impl/saga/InMemorySagaCoordinator.java +++ b/camel-core/src/main/java/org/apache/camel/impl/saga/InMemorySagaCoordinator.java @@ -87,7 +87,9 @@ public class InMemorySagaCoordinator implements CamelSagaCoordinator { try { values.put(option, expression.evaluate(exchange, Object.class)); } catch (Exception ex) { - return CompletableFuture.supplyAsync(() -> {throw new RuntimeCamelException("Cannot evaluate saga option '" + option + "'", ex);}); + return CompletableFuture.supplyAsync(() -> { + throw new RuntimeCamelException("Cannot evaluate saga option '" + option + "'", ex); + }); } } } diff --git a/camel-core/src/main/java/org/apache/camel/processor/saga/SagaProcessor.java b/camel-core/src/main/java/org/apache/camel/processor/saga/SagaProcessor.java index 95b94f2..a3a6d50 100644 --- a/camel-core/src/main/java/org/apache/camel/processor/saga/SagaProcessor.java +++ b/camel-core/src/main/java/org/apache/camel/processor/saga/SagaProcessor.java @@ -101,7 +101,8 @@ public abstract class SagaProcessor extends DelegateAsyncProcessor { ifNotException(ex, exchange, false, null, null, callback, code); } - protected void ifNotException(Throwable ex, Exchange exchange, boolean handleCompletion, CamelSagaCoordinator coordinator, CamelSagaCoordinator previousCoordinator, AsyncCallback callback, Runnable code) { + protected void ifNotException(Throwable ex, Exchange exchange, boolean handleCompletion, CamelSagaCoordinator coordinator, + CamelSagaCoordinator previousCoordinator, AsyncCallback callback, Runnable code) { if (ex != null) { exchange.setException(ex); if (handleCompletion) { -- To stop receiving notification emails like this one, please contact davscl...@apache.org.