Return-Path: Delivered-To: apmail-geronimo-activemq-users-archive@www.apache.org Received: (qmail 24817 invoked from network); 15 Jun 2006 13:45:30 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (209.237.227.199) by minotaur.apache.org with SMTP; 15 Jun 2006 13:45:30 -0000 Received: (qmail 67721 invoked by uid 500); 15 Jun 2006 13:45:26 -0000 Delivered-To: apmail-geronimo-activemq-users-archive@geronimo.apache.org Received: (qmail 67675 invoked by uid 500); 15 Jun 2006 13:45:26 -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 67653 invoked by uid 99); 15 Jun 2006 13:45:26 -0000 Received: from asf.osuosl.org (HELO asf.osuosl.org) (140.211.166.49) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 15 Jun 2006 06:45:26 -0700 X-ASF-Spam-Status: No, hits=2.0 required=10.0 tests=RCVD_IN_BL_SPAMCOP_NET,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (asf.osuosl.org: domain of james.strachan@gmail.com designates 66.249.92.174 as permitted sender) Received: from [66.249.92.174] (HELO ug-out-1314.google.com) (66.249.92.174) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 15 Jun 2006 06:45:25 -0700 Received: by ug-out-1314.google.com with SMTP id m3so1024832uge for ; Thu, 15 Jun 2006 06:45:04 -0700 (PDT) DomainKey-Signature: a=rsa-sha1; q=dns; c=nofws; s=beta; d=gmail.com; h=received:message-id:date:from:to:subject:in-reply-to:mime-version:content-type:content-transfer-encoding:content-disposition:references; b=PjYaoOoeE8ifN7OJ9EN04+5d6S0XzkoHYONZpxT/ZtY9fZ+jkdBgbAUwQDSxY4LejEcmmlY9J/QJiTORcsLqfMebaAJaMdZ/T08H87PaBLOFb2HWd8r0y5ojKq1V+/m3wP+ffAFE4z41mSpfRyR9uZB9iOYl/LNGeHOBGK3bmgU= Received: by 10.67.96.14 with SMTP id y14mr1734968ugl; Thu, 15 Jun 2006 06:45:04 -0700 (PDT) Received: by 10.66.255.17 with HTTP; Thu, 15 Jun 2006 06:45:04 -0700 (PDT) Message-ID: Date: Thu, 15 Jun 2006 14:45:04 +0100 From: "James Strachan" To: activemq-users@geronimo.apache.org Subject: Re: limit the number of messages per second In-Reply-To: <001FD7EB9646934B9237F09DE8E1F07C02F8C146@DE0-MAILMB02.res.airbus.corp> MIME-Version: 1.0 Content-Type: text/plain; charset=ISO-8859-1; format=flowed Content-Transfer-Encoding: 7bit Content-Disposition: inline References: <001FD7EB9646934B9237F09DE8E1F07C02F8C146@DE0-MAILMB02.res.airbus.corp> X-Virus-Checked: Checked by ClamAV on apache.org X-Spam-Rating: minotaur.apache.org 1.6.2 0/1000/N On 6/15/06, Gerdes, Mike wrote: > > I want this feature to make AMQ a bit more stable, to reduce network traffic and prevent flooding and to avoid that a software with errors kills my system. You can use the prefetch for that... http://incubator.apache.org/activemq/what-is-the-prefetch-limit-for.html to limit how many messages are dispatched to a consumer. > From what I noticed is that AMQ does have some memory problems and that it hits under certain circumstances 100 used memory and crashes then. Whats the crash? Is this the broker or client? > But thats the smaller reason. The major reason is just for security. In my testing and application I need to have a system that is more or less stable and secure. And DoS and flooding of queues seems to me a big problem. How about using security so only nodes you trust can publish to your queues? > One thing about the memory problem, I have encountered. With more then one consumer and using queue, AMQ crashes with 100% used memory if I send as fast as possible. This happens with and without async messages. What I noticed is that the usageManagers request more and more memory and at some point don't get it and then block. When a message from a queue is read, its memory is not freed. With only on consumer this haven'T been the case. There has the memory be freed. > (I put reference counter System.out.println into the usageManger) Which version of ActiveMQ are you using? Also are you using persistent queues? (I'm guessing not as that is not memory bound). If you are using 4.0 have you disabled optimizeAck? (see the known issues) http://incubator.apache.org/activemq/activemq-40-release.html -- James ------- http://radio.weblogs.com/0112098/