Return-Path: X-Original-To: apmail-camel-users-archive@www.apache.org Delivered-To: apmail-camel-users-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id D8CF7106CA for ; Tue, 21 Jan 2014 21:09:03 +0000 (UTC) Received: (qmail 59899 invoked by uid 500); 21 Jan 2014 21:09:02 -0000 Delivered-To: apmail-camel-users-archive@camel.apache.org Received: (qmail 59873 invoked by uid 500); 21 Jan 2014 21:09:02 -0000 Mailing-List: contact users-help@camel.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@camel.apache.org Delivered-To: mailing list users@camel.apache.org Received: (qmail 59865 invoked by uid 99); 21 Jan 2014 21:09:02 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 21 Jan 2014 21:09:02 +0000 X-ASF-Spam-Status: No, hits=2.8 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS,URI_HEX X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of richardkettelerij@gmail.com designates 209.85.128.169 as permitted sender) Received: from [209.85.128.169] (HELO mail-ve0-f169.google.com) (209.85.128.169) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 21 Jan 2014 21:08:55 +0000 Received: by mail-ve0-f169.google.com with SMTP id oy12so3483032veb.0 for ; Tue, 21 Jan 2014 13:08:34 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:in-reply-to:references:from:date:message-id:subject:to :content-type; bh=4gnJc6PRUDMLPnFnDqcQ2XpYJVwbX5Bt6msUN8tk4v0=; b=Qd+2FhBmeE/y+9SwaTi1bNDDcQBiDUd5OHWpW4/CnKbAuAtM308n8YkKT0KPU8eUbK 8F/7T9Gusg5zTrr0AX7pHvsZSw4wn9M8M+JA+CZXTwV2p1FoT1js5F3qW3zq+0M67Zxe hKz2Wdef9zfU+Rf6tzGSNUJ0HteT4lT6/YgEgisQAPbDQZ/j8R52s/v5LvwxJMWLw1bP XsRB22hIRpLKnrXOrz7HRgt+GbEchF4JkoEnVzrr3DV2KAytAVfewe0v51EhWZSuOsz9 KQEovMTJm6ZCcsy1iE2OTxzw1xxoccwFpdxo79x3snOMexX5sbYGiWDEsF/qQ9Avhttt cWag== X-Received: by 10.58.181.230 with SMTP id dz6mr2121982vec.35.1390338514834; Tue, 21 Jan 2014 13:08:34 -0800 (PST) MIME-Version: 1.0 Received: by 10.220.197.130 with HTTP; Tue, 21 Jan 2014 13:08:14 -0800 (PST) In-Reply-To: <1390332387921-5746304.post@n5.nabble.com> References: <1390309942845-5746278.post@n5.nabble.com> <1390332387921-5746304.post@n5.nabble.com> From: Richard Kettelerij Date: Tue, 21 Jan 2014 22:08:14 +0100 Message-ID: Subject: Re: Avoiding duplicate messages To: "users@camel.apache.org" Content-Type: multipart/alternative; boundary=047d7b673bda4b5ac304f081694d X-Virus-Checked: Checked by ClamAV on apache.org --047d7b673bda4b5ac304f081694d Content-Type: text/plain; charset=ISO-8859-1 Hi Atanas, > However, the usage of this EIP requires modification of the original route > (insertion of an idempotentConsumer instruction before every destination > endpoint) and I would prefer to use an alternative approach (if it's > possible). Why would modifying the route (e.g. inserting idempotent consumers) be a problem? > Does the exchange keep information about which route endpoints have > successfully processed it? Maybe it's the exchange's unit of execution > holding this info? Take a look at the message history of the exchange: http://camel.apache.org/message-history.html Also as you can read on the above page you can also use the Java AP of the UnitOfWork: http://camel.apache.org/maven/current/camel-core/apidocs/org/apache/camel/spi/TracedRouteNodes.html. E.g: exchange.getUnitOfWork().getTracedRouteNodes().getNodes(). But I think using an idempotent consumer is easier. Kind regards, Richard On Tue, Jan 21, 2014 at 8:26 PM, Atanas Shindov wrote: > Hi Richard, > > thanks for your prompt reply. > > It looks like the Idempotent Consumer might help, especially if in it's > File/JDBC based implementations the message ids are durably persisted (it > seems quite logical to be so), so that they are available after a JVM > restart for example. > > However, the usage of this EIP requires modification of the original route > (insertion of an idempotentConsumer instruction before every destination > endpoint) and I would prefer to use an alternative approach (if it's > possible). > > Does the exchange keep information about which route endpoints have > successfully processed it? Maybe it's the exchange's unit of execution > holding this info? > > Thanks again for your help. > > Best regards, > Atanas > > > > -- > View this message in context: > http://camel.465427.n5.nabble.com/Avoiding-duplicate-messages-tp5746278p5746304.html > Sent from the Camel - Users mailing list archive at Nabble.com. > --047d7b673bda4b5ac304f081694d--