Repository: camel Updated Branches: refs/heads/master 1e67be585 -> 8653f41a1
CAMEL-7282: onException should enable backoffMultiplier or collision avodiance if end user configured a value, just as the errorHandler Java DSL does. Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/8653f41a Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/8653f41a Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/8653f41a Branch: refs/heads/master Commit: 8653f41a1a809367d3334869d87adf0ab9acee96 Parents: 1e67be5 Author: Claus Ibsen <davscl...@apache.org> Authored: Tue Mar 11 07:39:41 2014 +0100 Committer: Claus Ibsen <davscl...@apache.org> Committed: Tue Mar 11 07:39:49 2014 +0100 ---------------------------------------------------------------------- .../main/java/org/apache/camel/model/OnExceptionDefinition.java | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/8653f41a/camel-core/src/main/java/org/apache/camel/model/OnExceptionDefinition.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/model/OnExceptionDefinition.java b/camel-core/src/main/java/org/apache/camel/model/OnExceptionDefinition.java index 787732c..829f402 100644 --- a/camel-core/src/main/java/org/apache/camel/model/OnExceptionDefinition.java +++ b/camel-core/src/main/java/org/apache/camel/model/OnExceptionDefinition.java @@ -380,6 +380,7 @@ public class OnExceptionDefinition extends ProcessorDefinition<OnExceptionDefini * @return the builder */ public OnExceptionDefinition backOffMultiplier(double backOffMultiplier) { + getOrCreateRedeliveryPolicy().useExponentialBackOff(); getOrCreateRedeliveryPolicy().backOffMultiplier(backOffMultiplier); return this; } @@ -391,6 +392,7 @@ public class OnExceptionDefinition extends ProcessorDefinition<OnExceptionDefini * @return the builder */ public OnExceptionDefinition backOffMultiplier(String backOffMultiplier) { + getOrCreateRedeliveryPolicy().useExponentialBackOff(); getOrCreateRedeliveryPolicy().backOffMultiplier(backOffMultiplier); return this; } @@ -402,6 +404,7 @@ public class OnExceptionDefinition extends ProcessorDefinition<OnExceptionDefini * @return the builder */ public OnExceptionDefinition collisionAvoidanceFactor(double collisionAvoidanceFactor) { + getOrCreateRedeliveryPolicy().useCollisionAvoidance(); getOrCreateRedeliveryPolicy().collisionAvoidanceFactor(collisionAvoidanceFactor); return this; } @@ -413,6 +416,7 @@ public class OnExceptionDefinition extends ProcessorDefinition<OnExceptionDefini * @return the builder */ public OnExceptionDefinition collisionAvoidanceFactor(String collisionAvoidanceFactor) { + getOrCreateRedeliveryPolicy().useCollisionAvoidance(); getOrCreateRedeliveryPolicy().collisionAvoidanceFactor(collisionAvoidanceFactor); return this; } @@ -424,6 +428,7 @@ public class OnExceptionDefinition extends ProcessorDefinition<OnExceptionDefini * @return the builder */ public OnExceptionDefinition collisionAvoidancePercent(double collisionAvoidancePercent) { + getOrCreateRedeliveryPolicy().useCollisionAvoidance(); getOrCreateRedeliveryPolicy().collisionAvoidancePercent(collisionAvoidancePercent); return this; }
