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 2018/06/09 12:14:48 UTC
[camel] 02/02: Fixed CS
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 <cl...@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
davsclaus@apache.org.