Adds JdbcAggregationRepository java doc to make clear that deadletter will be tried until it succeed
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/3bf98475 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/3bf98475 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/3bf98475 Branch: refs/heads/master Commit: 3bf9847506cc0f963e3d5b0c6bc7774b0aab3f4e Parents: cf8670e Author: Jonathan Schoreels <jonathan.schore...@gmail.com> Authored: Sun Apr 23 16:07:53 2017 +0200 Committer: Jonathan Schoreels <jonathan.schore...@gmail.com> Committed: Sun Apr 23 16:07:53 2017 +0200 ---------------------------------------------------------------------- .../camel/processor/aggregate/jdbc/JdbcAggregationRepository.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/3bf98475/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregationRepository.java ---------------------------------------------------------------------- diff --git a/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregationRepository.java b/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregationRepository.java index 801759b..ef5712c 100644 --- a/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregationRepository.java +++ b/components/camel-sql/src/main/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregationRepository.java @@ -424,6 +424,8 @@ public class JdbcAggregationRepository extends ServiceSupport implements Recover * * @param deadLetterUri An endpoint uri for a Dead Letter Channel where exhausted recovered Exchanges will be * moved. If this option is used then the maximumRedeliveries option must also be provided. + * Important note : if the deadletter route throws an exception, it will be send again to DLQ + * until it succeed ! */ public void setDeadLetterUri(String deadLetterUri) { this.deadLetterUri = deadLetterUri;
