Return-Path: Delivered-To: apmail-activemq-users-archive@www.apache.org Received: (qmail 86741 invoked from network); 12 Mar 2009 08:43:11 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 12 Mar 2009 08:43:11 -0000 Received: (qmail 54666 invoked by uid 500); 12 Mar 2009 08:43:09 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 54648 invoked by uid 500); 12 Mar 2009 08:43:09 -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 54637 invoked by uid 99); 12 Mar 2009 08:43:09 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 12 Mar 2009 01:43:09 -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: local policy) Received: from [192.77.186.17] (HELO mx3.progress.com) (192.77.186.17) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 12 Mar 2009 08:43:00 +0000 Received: from mx3.progress.com (127.0.0.1) by mx3.progress.com (MlfMTA v3.2r9) id hn35h80171s2 for ; Thu, 12 Mar 2009 04:42:40 -0400 (envelope-from ) Received: from progress.com ([192.233.92.16]) by mx3.progress.com (SonicWALL 6.2.2.1073) with ESMTP; Thu, 12 Mar 2009 04:42:39 -0400 Received: from NTEXFE01.bedford.progress.com (ntexfe01 [10.128.10.24]) by progress.com (8.13.8/8.13.8) with ESMTP id n2C8gdS6024601 for ; Thu, 12 Mar 2009 04:42:39 -0400 (EDT) Received: from 9b8bf1j.emea.progress.com ([172.21.9.62]) by NTEXFE01.bedford.progress.com over TLS secured channel with Microsoft SMTPSVC(6.0.3790.3959); Thu, 12 Mar 2009 04:42:38 -0400 Message-Id: From: Andreas Gies To: users@activemq.apache.org In-Reply-To: <22463774.post@talk.nabble.com> Content-Type: text/plain; charset=WINDOWS-1252; format=flowed; delsp=yes Content-Transfer-Encoding: quoted-printable Mime-Version: 1.0 (Apple Message framework v930.3) Subject: Re: Fast producers,slow consumer... queue growing forever Date: Thu, 12 Mar 2009 09:42:37 +0100 References: <22373306.post@talk.nabble.com> <22460136.post@talk.nabble.com> <22463774.post@talk.nabble.com> X-Mailer: Apple Mail (2.930.3) X-OriginalArrivalTime: 12 Mar 2009 08:42:39.0175 (UTC) FILETIME=[80181D70:01C9A2EE] X-Mlf-Version: 6.2.2.1073 X-Mlf-UniqueId: o200903120842390219786 X-Virus-Checked: Checked by ClamAV on apache.org Hi, I am glad the answer helped a bit. It would be great if you could turn =20= your test app into a JUnit test and log a JIRA for your issue. Best regards Andreas On Mar 11, 2009, at 9:27 PM, Yenki wrote: > > Hi Andreas, > > thanks for your help! We also managed to make memory limit work on =20 > 5.2. But > we still have problemes with message eviction. I'v create a small > application to test it while stepping in ActiveMQ code. What I found =20= > is that > one evicted message out of two is redirected to the client. I'm almost > convinced there is a bug there. > does Anybody have the same problem? > > Yannick > > Andreas Gies-3 wrote: >> >> Hi there, >> >> I have run into a similar issue with a later version of ActiveMQ and >> have blogged about that. >> Perhaps that helps you: >> = http://open-source-adventures.blogspot.com/2009/01/limiting-disk-store-usa= ge-with-active.html >> >> Best regards >> Andreas >> >> On Mar 11, 2009, at 6:24 PM, pclovec wrote: >> >>> >>> Make met same problem >>> >>> Yenki wrote: >>>> >>>> Hi, for the last few days I=92ve been trying to solve a fast >>>> producers / >>>> slow consumer problem. I want a limited amount of messages fetch on >>>> the >>>> consumer (this works) but I also want to have a limited amount of >>>> messages >>>> in the queue itself (doesn=92t work). I use ActiveMQ 4.1.2 Here is >>>> what I >>>> tried: >>>> >>>> #1 Setup destinations policies >>>> I added this to my activemq.xml >>>> >>>> >>>> >>>> "> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> How can I know if my policies are applied? They don=92t seem to be >>>> because >>>> when I run my application my queue is growing until out of memory. >>>> What I >>>> see from JMX=85 >>>> -QueueSize of my queue growing forever (with prefetch of 20 & =20 >>>> pending >>>> limit of 10 I would expect a max of 30 right?) >>>> -MaximumPendingMessageLimit=3D0 for the non-durable subscription to >>>> this >>>> queue >>>> >>>> >>>> #2 Queue configurations >>>> I tried to set MaximumPendingMessageLimit when I create the queue. >>>> mySession.createQueue(=93MyQueue=94 + >>>> "?=20 >>>> consumer.prefetchSize=3D20&consumer.maximumPendingMessageLimit=3D10")= ; >>>> >>>> What I see from JMX=85 >>>> -QueueSize of my queue growing forever >>>> -The value for the non-durable subscription to this queue are: >>>> MaximumPendingMessageLimit=3D10 >>>> PrefetchSize=3D20 >>>> >>>> #3 Memory limit >>>> As a last resort I tried to set a memory limit on my policyEntry >>>> and on my >>>> broker and it is still growing forever. >>>> =46rom JMX I see the MemoryPercentageUsed always to 0 for both = broker >>>> and >>>> Queue. I run Broken embedded in the same VM than my application. >>>> Maybe it >>>> can explain why. >>>> >>>> Could someone help me make my PendingMessageLimit works so I don=92t >>>> run out >>>> of memory. >>>> Thanks for your help >>>> >>>> Yannick >>>> >>>> >>>> >>> >>> --=20 >>> View this message in context: >>> = http://www.nabble.com/Fast-producers%2Cslow-consumer...-queue-growing-fore= ver-tp22373306p22460136.html >>> Sent from the ActiveMQ - User mailing list archive at Nabble.com. >>> >> >> --- >> Mit freundlichen Gr=FCssen - Kind Regards >> Andreas Gies >> Principal Consultant >> Open Source Center of Competence >> >> Progress Software GmbH >> Agrippinawerft 26 >> 50678 K=F6ln >> >> E-Mail agies@progress.com >> Direct Line +49 (0)9953 980349 >> Mobile +49 (0)170 5759611 >> Skype +44 (0)20 3239 2922 >> Skype +353 (0)1 443 4971 >> Skype +1 (0)781 262 0168 >> >> http://www.progress.com >> http://fusesource.com >> http://open-source-adventures.blogspot.com >> >> >> >> ------------------------------------------------------- >> Progress Software GmbH >> Sitz der Gesellschaft: Agrippinawerft 26, 50678 Koeln; >> Niederlassung: Fuerstenrieder Str. 279, 81377 Muenchen >> Amtsgericht Koeln, HRB 15620; >> Geschaeftsfuehrung: David Ireland >> ------------------------------------------------------- >> >> > > --=20 > View this message in context: = http://www.nabble.com/Fast-producers%2Cslow-consumer...-queue-growing-fore= ver-tp22373306p22463774.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com. > --- Mit freundlichen Gr=FCssen - Kind Regards Andreas Gies Principal Consultant Open Source Center of Competence Progress Software GmbH Agrippinawerft 26 50678 K=F6ln E-Mail agies@progress.com Direct Line +49 (0)9953 980349 Mobile +49 (0)170 5759611 Skype +44 (0)20 3239 2922 Skype +353 (0)1 443 4971 Skype +1 (0)781 262 0168 http://www.progress.com http://fusesource.com http://open-source-adventures.blogspot.com ------------------------------------------------------- Progress Software GmbH Sitz der Gesellschaft: Agrippinawerft 26, 50678 Koeln; Niederlassung: Fuerstenrieder Str. 279, 81377 Muenchen Amtsgericht Koeln, HRB 15620; Geschaeftsfuehrung: David Ireland -------------------------------------------------------