Return-Path: Delivered-To: apmail-geronimo-activemq-users-archive@www.apache.org Received: (qmail 96055 invoked from network); 28 Jul 2006 05:30:52 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (209.237.227.199) by minotaur.apache.org with SMTP; 28 Jul 2006 05:30:52 -0000 Received: (qmail 29025 invoked by uid 500); 28 Jul 2006 05:30:51 -0000 Delivered-To: apmail-geronimo-activemq-users-archive@geronimo.apache.org Received: (qmail 28841 invoked by uid 500); 28 Jul 2006 05:30:51 -0000 Mailing-List: contact activemq-users-help@geronimo.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: activemq-users@geronimo.apache.org Delivered-To: mailing list activemq-users@geronimo.apache.org Received: (qmail 28832 invoked by uid 99); 28 Jul 2006 05:30:51 -0000 Received: from asf.osuosl.org (HELO asf.osuosl.org) (140.211.166.49) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 27 Jul 2006 22:30:51 -0700 X-ASF-Spam-Status: No, hits=-0.0 required=10.0 tests=SPF_HELO_PASS,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (asf.osuosl.org: domain of lists@nabble.com designates 72.21.53.35 as permitted sender) Received: from [72.21.53.35] (HELO talk.nabble.com) (72.21.53.35) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 27 Jul 2006 22:30:49 -0700 Received: from [72.21.53.38] (helo=jubjub.nabble.com) by talk.nabble.com with esmtp (Exim 4.50) id 1G6Kvc-00031e-RP for activemq-users@geronimo.apache.org; Thu, 27 Jul 2006 22:30:28 -0700 Message-ID: <5533929.post@talk.nabble.com> Date: Thu, 27 Jul 2006 22:30:28 -0700 (PDT) From: nlif To: activemq-users@geronimo.apache.org Subject: Re: Consuming a group of messages in a single transaction In-Reply-To: MIME-Version: 1.0 Content-Type: text/plain; charset=us-ascii Content-Transfer-Encoding: 7bit X-Nabble-Sender: naaman@dbnet.co.il X-Nabble-From: nlif References: <5397996.post@talk.nabble.com> <5518879.post@talk.nabble.com> X-Virus-Checked: Checked by ClamAV on apache.org X-Spam-Rating: minotaur.apache.org 1.6.2 0/1000/N Thanks, Hiram. I guess I need to take a step back then, and restate my question in a more generalized form: how is it possible in a JMS-based architecture to send/receive several seperate items, while ensuring atomicy of the group? That is - it is ensured that ALL items of the group are received, and by the SAME consumer. At first, I thought using JMS transactions (both on the producer and on the consumer side) will suffice, but then I realized in a cluster (or even a multi-threaded single-node consumer) the group might get scattered among several consumers. ActiveMQ MessageGroups then came to the rescue - I am using an AMQ group, as one would use a transaction, to ensure all items are delivered to the same consumer (and the consumer will commit only after it has received all items in the group). However, now with the need to pass very large binary files, for which I must use streams, it seems I am running out of options. Maybe it is time to rethink the whole concept... so, is there another architecture for such a requirement? Seems to me this is somewhat of a generic problem for any messaging-based archiecture, and I would think there is some "design-pattern" solution for it. Is there? Thanks, Naaman -- View this message in context: http://www.nabble.com/Consuming-a-group-of-messages-in-a-single-transaction-tf1966918.html#a5533929 Sent from the ActiveMQ - User forum at Nabble.com.