Return-Path: Delivered-To: apmail-geronimo-activemq-dev-archive@www.apache.org Received: (qmail 17903 invoked from network); 8 Apr 2006 15:01:54 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (209.237.227.199) by minotaur.apache.org with SMTP; 8 Apr 2006 15:01:54 -0000 Received: (qmail 11908 invoked by uid 500); 8 Apr 2006 15:01:54 -0000 Delivered-To: apmail-geronimo-activemq-dev-archive@geronimo.apache.org Received: (qmail 11871 invoked by uid 500); 8 Apr 2006 15:01:53 -0000 Mailing-List: contact activemq-dev-help@geronimo.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: activemq-dev@geronimo.apache.org Delivered-To: mailing list activemq-dev@geronimo.apache.org Received: (qmail 11862 invoked by uid 99); 8 Apr 2006 15:01:53 -0000 Received: from asf.osuosl.org (HELO asf.osuosl.org) (140.211.166.49) by apache.org (qpsmtpd/0.29) with ESMTP; Sat, 08 Apr 2006 08:01:53 -0700 X-ASF-Spam-Status: No, hits=0.0 required=10.0 tests= X-Spam-Check-By: apache.org Received-SPF: neutral (asf.osuosl.org: local policy) Received: from [64.14.253.135] (HELO goku.simulalabs.com) (64.14.253.135) by apache.org (qpsmtpd/0.29) with ESMTP; Sat, 08 Apr 2006 08:01:52 -0700 Received: by goku.simulalabs.com (Postfix, from userid 501) id 7167AEC04BD; Sat, 8 Apr 2006 08:01:31 -0700 (PDT) Received: from localhost (goku [127.0.0.1]) by goku.simulalabs.com (Postfix) with ESMTP id 4144CEC04A3 for ; Sat, 8 Apr 2006 08:01:31 -0700 (PDT) Received: from goku.simulalabs.com ([127.0.0.1]) by localhost (goku.simulalabs.com [127.0.0.1]) (amavisd-new, port 10024) with LMTP id 28833-05 for ; Sat, 8 Apr 2006 08:01:28 -0700 (PDT) Received: from speedo (jira.activemq.org [172.18.20.169]) by goku.simulalabs.com (Postfix) with ESMTP id 261B7EC04B8 for ; Sat, 8 Apr 2006 08:01:28 -0700 (PDT) Message-ID: <14494406.1144515797777.JavaMail.tomcat@speedo> Date: Sat, 8 Apr 2006 10:03:17 -0700 (PDT) From: "james strachan (JIRA)" To: activemq-dev@geronimo.apache.org Subject: [jira] Commented: (AMQ-394) for non-durable topics add a configurable Policy to drop messages from slow consumers MIME-Version: 1.0 Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: 7bit X-Virus-Scanned: amavisd-new at goku.simulalabs.com X-DSPAM-Result: Whitelisted X-DSPAM-Processed: Sat Apr 8 08:01:31 2006 X-DSPAM-Confidence: 0.9899 X-DSPAM-Probability: 0.0000 X-DSPAM-Signature: 4437d04b291386247014846 X-DSPAM-Factors: 27, something?+This, 0.01000, Subject*(AMQ, 0.01000, Date*8+Apr, 0.01000, Return-Path*, 0.01000, Received*28833, 0.01000, Subject*drop, 0.01000, Subject*394)+for, 0.01000, slow+consumers, 0.01000, old+price, 0.01000, things+back, 0.01000, but+discard, 0.01000, Similarly+we, 0.01000, g+for, 0.01000, FlowControlPolicy, 0.01000, Url*org/jira//secure/Administrators, 0.01000, Similarly, 0.01000, New+Feature, 0.01000, 394, 0.01000, 394, 0.01000 X-Virus-Checked: Checked by ClamAV on apache.org X-Spam-Rating: minotaur.apache.org 1.6.2 0/1000/N [ http://jira.activemq.org/jira//browse/AMQ-394?page=comments#action_35910 ] james strachan commented on AMQ-394: ------------------------------------ We now can eagerly evict timed out messages; we have a high watermark for how many pending messages are avalable before we try to evict > for non-durable topics add a configurable Policy to drop messages from slow consumers > ------------------------------------------------------------------------------------- > > Key: AMQ-394 > URL: http://jira.activemq.org/jira//browse/AMQ-394 > Project: ActiveMQ > Type: New Feature > Components: Broker > Reporter: james strachan > Fix For: 4.1 > > > e.g. for market data pricing we may wish to only allow say 1000 pending messages but discard old messages rather than have things back up. Similarly we may wish to do something like remove old price changes for the same stock and just keep around the latest prices. > So some kind of pluggable policy on the non-durable topic subscription would be a good idea, letting users customize this behaviour. > Maybe some FlowControlPolicy or something? -- This message is automatically generated by JIRA. - If you think it was sent incorrectly contact one of the administrators: http://jira.activemq.org/jira//secure/Administrators.jspa - For more information on JIRA, see: http://www.atlassian.com/software/jira