Return-Path: Delivered-To: apmail-activemq-users-archive@www.apache.org Received: (qmail 81753 invoked from network); 1 Jun 2008 05:31:45 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 1 Jun 2008 05:31:45 -0000 Received: (qmail 23520 invoked by uid 500); 1 Jun 2008 05:31:47 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 23504 invoked by uid 500); 1 Jun 2008 05:31:47 -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 23493 invoked by uid 99); 1 Jun 2008 05:31:47 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Sat, 31 May 2008 22:31:47 -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 james.strachan@gmail.com designates 64.233.178.245 as permitted sender) Received: from [64.233.178.245] (HELO hs-out-0708.google.com) (64.233.178.245) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 01 Jun 2008 05:30:57 +0000 Received: by hs-out-0708.google.com with SMTP id j58so364040hsj.6 for ; Sat, 31 May 2008 22:31:13 -0700 (PDT) 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:in-reply-to:mime-version:content-type:content-transfer-encoding:content-disposition:references; bh=WvW19tcltEbwYTly1j1yTfJkWWLaqe3x8Va7Mg02j0g=; b=B8PyQT19TIWFO/vtqT9jVwu3e1a7GA9FoLRpkRX+QjuKtprE6Fp81lii96QQMM7luqjpmY1eRTWd5MfG9PzvZGxWvUSqCk1gdQwKiQ4VxiPKEvQvqdR+/LgBXz2U/10SVN8IQjz5Qeq2vNSEv3dg/XtHdRHhcovKUgS7UlPdR8E= DomainKey-Signature: a=rsa-sha1; c=nofws; d=gmail.com; s=gamma; h=message-id:date:from:to:subject:in-reply-to:mime-version:content-type:content-transfer-encoding:content-disposition:references; b=jv25MiM3CGKXf18vvcajBiczlvrYoZotqfsrXBVEV5JcK3q19dPAffatmSWzUb6V/qUTUYaZvdPFC8zmgreXAQHC80tn1yZStE4xdQMkaaxZiP29gw8qb8cV8FDNwJaKG6j+SNK8syHH6m7U9ZN3dITHyy5HBbiZ0rSsWyXwdOU= Received: by 10.90.97.20 with SMTP id u20mr9024150agb.31.1212298272698; Sat, 31 May 2008 22:31:12 -0700 (PDT) Received: by 10.90.82.6 with HTTP; Sat, 31 May 2008 22:31:12 -0700 (PDT) Message-ID: Date: Sun, 1 Jun 2008 06:31:12 +0100 From: "James Strachan" To: users@activemq.apache.org Subject: Re: Message Groups: Not working with Mule 2.0.1 feeding AMQ 5.1 In-Reply-To: MIME-Version: 1.0 Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: 7bit Content-Disposition: inline References: <17493075.post@talk.nabble.com> <74e15baa0805270917w256aabfcn107194c943c0e330@mail.gmail.com> <17495601.post@talk.nabble.com> X-Virus-Checked: Checked by ClamAV on apache.org FWIW zero means 'close the message group down'. Just make sure its not zero (or remove the header) and you're sorted 2008/5/27 Rob Davies : > > 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. >> > > -- James ------- http://macstrac.blogspot.com/ Open Source Integration http://open.iona.com