From users-return-17131-apmail-activemq-users-archive=activemq.apache.org@activemq.apache.org Wed Dec 03 08:16:17 2008 Return-Path: Delivered-To: apmail-activemq-users-archive@www.apache.org Received: (qmail 1873 invoked from network); 3 Dec 2008 08:16:17 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 3 Dec 2008 08:16:17 -0000 Received: (qmail 86333 invoked by uid 500); 3 Dec 2008 08:16:28 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 86312 invoked by uid 500); 3 Dec 2008 08:16:28 -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 86301 invoked by uid 99); 3 Dec 2008 08:16:28 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 03 Dec 2008 00:16:28 -0800 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 74.125.46.156 as permitted sender) Received: from [74.125.46.156] (HELO yw-out-1718.google.com) (74.125.46.156) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 03 Dec 2008 08:14:57 +0000 Received: by yw-out-1718.google.com with SMTP id 6so1240018ywa.86 for ; Wed, 03 Dec 2008 00:15:43 -0800 (PST) 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=cm+iH6TosF7PAgky9f7EbekcUIwpNfQDHevd8bmR2cw=; b=nQyCuyBSzG9ESWP0Vx57tEt4eX/kDkUHHBwMg27G7QqUlVSBRwvFKgbprUSZVuxEkW EZnVdDAGnIp5ByBHKMXuN4Yutl21a1r9QK54z+Ukb8u8Kss9f3GeQeBue0Il+1OB7BvZ 8RKqRpdLbUuebCwILV6qYHskoZdSGJcJc7uY4= 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=AVWxyFTz1i4NIn5eyqZOSCvSGlq+0yykQUMQhONVVVX5Di++ubeCADh0eKYTyAn0nk j4wiPRp1AHD0VlvMvK8Z4bVJWtqBG+fn6QV6KsJGR0wXfl3t7D7CI2TF9DapHmPR1mrA F02P+1rp35N9NbxM44xnoLZseWfcSE4wNUYdw= Received: by 10.151.42.6 with SMTP id u6mr25642200ybj.39.1228292143861; Wed, 03 Dec 2008 00:15:43 -0800 (PST) Received: from ?192.168.1.109? (host86-142-157-167.range86-142.btcentralplus.com [86.142.157.167]) by mx.google.com with ESMTPS id r28sm2905540ele.16.2008.12.03.00.15.42 (version=TLSv1/SSLv3 cipher=RC4-MD5); Wed, 03 Dec 2008 00:15:43 -0800 (PST) Message-Id: <44DBC45A-78EF-4BA8-8482-2F5D29EE1BF7@gmail.com> From: Rob Davies To: users@activemq.apache.org In-Reply-To: <20803736.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 v929.2) Subject: Re: message grouping not working? Date: Wed, 3 Dec 2008 08:15:36 +0000 References: <20627785.post@talk.nabble.com> <20803736.post@talk.nabble.com> X-Mailer: Apple Mail (2.929.2) X-Virus-Checked: Checked by ClamAV on apache.org Do you get the same results when the prefetch is zero? - see http://activemq.apache.org/what-is-the-prefetch-limit-for.html to see how to set prefetch limits cheers, Rob Rob Davies http://fusesource.com http://rajdavies.blogspot.com/ On 2 Dec 2008, at 23:52, skomarla wrote: > > hate bumping, but bump... Also, this might be related: > https://issues.apache.org/activemq/browse/AMQ-2016 > > If anyone has any input, it would be greatly appreciated. > > Thanks. > > > skomarla wrote: >> >> http://www.nabble.com/file/p20627785/msg-group-test.zip >> msg-group-test.zip >> >> I have posted my comments in >> https://issues.apache.org/activemq/browse/AMQ-1126 since I originally >> thought it might be related to the RA, but I'm not sure if it is >> localized >> to the RA. >> >> Attached is a unit test and some sample code.. It has a junit test >> with >> two tests in it. >> Both tests start out with sending some message to a same queue split >> across three different group ids (20 to group A, 10 to group B, 5 >> to group >> C). My understanding of message groups leads me to believe that the >> messages within a group are delivered sequentially, but across the >> groups >> they are delivered in parallel. >> >> If you look at the output of the unit tests, it does not seem to be >> the >> case. in many cases, it seems the messages get delivered in FIFO >> order >> ignoring groups entirely... in the listeners, I have setup various >> sleeps >> to simulate slow consumers.. When the message is from group C, the >> sleep >> time is small, and thus all 5 messages from group C should be >> delivered >> before the second message from group is delivered.. it does not >> seem to be >> the case >> >> 1 test uses the connection factory directly to setup message >> consumers, >> and another uses spring's listener container. Neither seem to do >> what I >> expect. Maybe I just have something setup horribly incorrectly, but >> I've >> seen the exact same bahaviour using the RA. >> >> Sorry for the double post, but I figured i'd post in the user forum >> as >> well.. soem log output is in the JIRA issue.. >> > > -- > View this message in context: http://www.nabble.com/message-grouping-not-working--tp20627785p20803736.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com. >