Return-Path: Delivered-To: apmail-activemq-users-archive@www.apache.org Received: (qmail 76292 invoked from network); 27 May 2008 18:02:33 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 27 May 2008 18:02:33 -0000 Received: (qmail 29963 invoked by uid 500); 27 May 2008 18:02:34 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 29938 invoked by uid 500); 27 May 2008 18:02:34 -0000 Mailing-List: contact users-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@activemq.apache.org Delivered-To: mailing list users@activemq.apache.org Received: (qmail 29926 invoked by uid 99); 27 May 2008 18:02:34 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 27 May 2008 11:02:33 -0700 X-ASF-Spam-Status: No, hits=0.2 required=10.0 tests=SPF_PASS,WHOIS_MYPRIVREG X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of rajdavies@gmail.com designates 66.249.92.168 as permitted sender) Received: from [66.249.92.168] (HELO ug-out-1314.google.com) (66.249.92.168) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 27 May 2008 18:01:44 +0000 Received: by ug-out-1314.google.com with SMTP id u2so524861uge.5 for ; Tue, 27 May 2008 11:02:00 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=domainkey-signature:received:received:message-id:from:to:in-reply-to:content-type:content-transfer-encoding:mime-version:subject:date:references:x-mailer; bh=6Y1QKQZkn46Mu6HYKkcHNxgO8dDyV++cPtzbupMS3Hc=; b=sr3w/OR3XvOoWH7ZtBJcTsKmwFd9QKmxGWvuMGuQkx9q25B66PduczokfKpNKZbqiUh2lZDgVbwuY9SeutGQmbodANBI7gDTyhOUjOxwoP2jYF7AEci2C5dz/KoYEQkkictpZbZBEB09xkFsPX/AHi9ClLoNJJxHuE5oogKALwc= DomainKey-Signature: a=rsa-sha1; c=nofws; d=gmail.com; s=gamma; h=message-id:from:to:in-reply-to:content-type:content-transfer-encoding:mime-version:subject:date:references:x-mailer; b=gW7OuEQmEMTh0G3YMwmMMLNhQQW3kAw01VD8urNnSWRS3dCIOpFclc0CozTDua7XB95A7V5RpAawkVx/a4Rw5f5KK0HNkMCbwUU8zwQJzv1VQG42VQik554ei+1OPQULR4BLZ0G1PfzXijzJh86uHKb+6BG1JRsgvrhOEC9PCx4= Received: by 10.67.27.3 with SMTP id e3mr5604535ugj.82.1211911319075; Tue, 27 May 2008 11:01:59 -0700 (PDT) Received: from ?192.168.1.75? ( [86.133.81.234]) by mx.google.com with ESMTPS id y34sm12921718iky.10.2008.05.27.11.01.57 (version=TLSv1/SSLv3 cipher=RC4-MD5); Tue, 27 May 2008 11:01:58 -0700 (PDT) Message-Id: From: Rob Davies To: users@activemq.apache.org In-Reply-To: <17495601.post@talk.nabble.com> Content-Type: text/plain; charset=US-ASCII; format=flowed; delsp=yes Content-Transfer-Encoding: 7bit Mime-Version: 1.0 (Apple Message framework v919.2) Subject: Re: Message Groups: Not working with Mule 2.0.1 feeding AMQ 5.1 Date: Tue, 27 May 2008 19:01:55 +0100 References: <17493075.post@talk.nabble.com> <74e15baa0805270917w256aabfcn107194c943c0e330@mail.gmail.com> <17495601.post@talk.nabble.com> X-Mailer: Apple Mail (2.919.2) X-Virus-Checked: Checked by ClamAV on apache.org On 27 May 2008, at 18:18, jcarreira wrote: > > I have no idea what the problem is... It could be something in the > way Mule > feeds into AMQ and how the sequence number on the messages is always > zero... That would do it ;) > > > > Aaron Mulder wrote: >> >> FWIW, Message Groups were working for me on a 5.1 server with a >> broker >> and one producer and several consumers all running in separate apps. >> So a test case would be really helpful (unless you think the problem >> is just when you have multiple producers). >> >> Thanks, >> Aaron >> >> On Tue, May 27, 2008 at 11:27 AM, jcarreira >> wrote: >>> >>> I was trying to use Mule 2.0.1 to read a directory and feed the file >>> contents >>> into an AMQ 5.1 Queue. The issue is that I need to handle files >>> with the >>> same first part of the file name (before the extension) serially >>> so as to >>> not have race conditions and optimistic concurrency exceptions. >>> Therefore >>> I >>> built a special Transformer to transform the Object I built from >>> the file >>> into a JMS message which sets the JMSXGroupID property. When >>> running all >>> in >>> one process, I see it finding the groupID and looking up the >>> consumer, >>> but >>> when I run it on 3 processes (feeder, AMQ, and processor) the >>> messages >>> are >>> getting read by different consumers / Threads and I get concurrent >>> modification exceptions. >>> >>> Anyone have any idea why it might be doing that or how to fix it? >>> -- >>> View this message in context: >>> http://www.nabble.com/Message-Groups%3A-Not-working-with-Mule-2.0.1-feeding-AMQ-5.1-tp17493075s2354p17493075.html >>> Sent from the ActiveMQ - User mailing list archive at Nabble.com. >>> >>> >>> >> >> > > -- > View this message in context: http://www.nabble.com/Message-Groups%3A-Not-working-with-Mule-2.0.1-feeding-AMQ-5.1-tp17493075s2354p17495601.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com. >