Return-Path: Delivered-To: apmail-activemq-camel-user-archive@locus.apache.org Received: (qmail 69158 invoked from network); 8 Jan 2009 17:36:12 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 8 Jan 2009 17:36:12 -0000 Received: (qmail 58107 invoked by uid 500); 8 Jan 2009 17:36:12 -0000 Delivered-To: apmail-activemq-camel-user-archive@activemq.apache.org Received: (qmail 58092 invoked by uid 500); 8 Jan 2009 17:36:12 -0000 Mailing-List: contact camel-user-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: camel-user@activemq.apache.org Delivered-To: mailing list camel-user@activemq.apache.org Received: (qmail 58081 invoked by uid 99); 8 Jan 2009 17:36:12 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 08 Jan 2009 09:36:12 -0800 X-ASF-Spam-Status: No, hits=-0.0 required=10.0 tests=SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of davisford@gmail.com designates 209.85.200.173 as permitted sender) Received: from [209.85.200.173] (HELO wf-out-1314.google.com) (209.85.200.173) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 08 Jan 2009 17:36:02 +0000 Received: by wf-out-1314.google.com with SMTP id 26so9946499wfd.26 for ; Thu, 08 Jan 2009 09:35:41 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=domainkey-signature:received:received:message-id:date:from:to :subject:mime-version:content-type:content-transfer-encoding :content-disposition; bh=0g5hzXG/bK20Qh0KP6+7iSdExef3T9bj5xm3JiGvwiI=; b=h3pCPSMye2MDJHXOXsr3kGR1CPISDwMbCgVYCey30DIflDI6kIeRBn/bH/WCJ69OJI l2Qv96eU0p1uL4JKxKK25bisld0ZIZhk/gYG0P+1Z0qe1dbB9RN1wUO5421KDboLtkVB D99ybVz4b6LgGcPnQ+XY3NUsSlCDeRHZ1+YhE= DomainKey-Signature: a=rsa-sha1; c=nofws; d=gmail.com; s=gamma; h=message-id:date:from:to:subject:mime-version:content-type :content-transfer-encoding:content-disposition; b=dpHCBIJ1z3E4U9cDZlcXQYJkWpRiW6o/eLx6Tbu05u2MKeuikxvDuOetOW3flw/1iU hudQ9l+zjgfp/ZEpQt/8IbS+jqHh7Xp7mJR5pjByJSofYmzzArGDh1vcwTTB8hSpLOOW 8oTpUUC+YsYeSijSmIlGdYu5mCRx18U1vZst0= Received: by 10.142.214.5 with SMTP id m5mr10268412wfg.110.1231436141744; Thu, 08 Jan 2009 09:35:41 -0800 (PST) Received: by 10.143.99.10 with HTTP; Thu, 8 Jan 2009 09:35:41 -0800 (PST) Message-ID: <9b5c3a2f0901080935o16cad7f9tca32a7fd8c363ccf@mail.gmail.com> Date: Thu, 8 Jan 2009 12:35:41 -0500 From: "Davis Ford" To: camel-user@activemq.apache.org Subject: questions on JPA component MIME-Version: 1.0 Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: 7bit Content-Disposition: inline X-Virus-Checked: Checked by ClamAV on apache.org Hi, regarding the @Consumed annotation http://activemq.apache.org/camel/maven/camel-jpa/apidocs/org/apache/camel/component/jpa/Consumed.html I'm a bit curious how this works. If I have the following setup: NodeA <----> OracleDB <----> NodeB Where I have a JpaProducer on NodeA and a JpaConsumer on NodeB And I have something like @Entity public class MyEntity { etc.. @Consumed public void consumed() { System.out.println("Message was consumed"); } } I tried this out in a single JVM test that hits an oracle database and it works. I get a callback on the @Consumed method. But in a distributed environment -- how does this work? How would the producer on NodeA know that the consumer on NodeB got the Exchange? Follow up question: The @Consumed annotation will come in really handy for me if I can get it to work the way I want. Here's what I am attempting to do: 1. Producer sends message 2. Consumer gets message 3. Consumer has to do some operation that may fail 3a. If it does fail I do not want the producer notified that the message was consumed 3b. If it does not fail, I want the producer notified so it can do some local cleanup Maybe the @Consumed is not what I want -- is there some way to insert a hook on the consumer side to control when the producer would get notified? Thanks in advance, Davis -- Zeno Consulting, Inc. http://www.zenoconsulting.biz 248.894.4922 phone 313.884.2977 fax