Return-Path: Delivered-To: apmail-geronimo-activemq-dev-archive@www.apache.org Received: (qmail 19458 invoked from network); 7 Apr 2006 13:57:59 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (209.237.227.199) by minotaur.apache.org with SMTP; 7 Apr 2006 13:57:59 -0000 Received: (qmail 35120 invoked by uid 500); 7 Apr 2006 13:57:56 -0000 Delivered-To: apmail-geronimo-activemq-dev-archive@geronimo.apache.org Received: (qmail 35094 invoked by uid 500); 7 Apr 2006 13:57:56 -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 35084 invoked by uid 99); 7 Apr 2006 13:57:56 -0000 Received: from asf.osuosl.org (HELO asf.osuosl.org) (140.211.166.49) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 07 Apr 2006 06:57:56 -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; Fri, 07 Apr 2006 06:57:55 -0700 Received: by goku.simulalabs.com (Postfix, from userid 501) id 35DD7EC049C; Fri, 7 Apr 2006 06:57:34 -0700 (PDT) Received: from localhost (goku [127.0.0.1]) by goku.simulalabs.com (Postfix) with ESMTP id D3F3BEC0498 for ; Fri, 7 Apr 2006 06:57:33 -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 19186-07 for ; Fri, 7 Apr 2006 06:57:32 -0700 (PDT) Received: from stilton (jira.activemq.org [172.18.20.169]) by goku.simulalabs.com (Postfix) with ESMTP id 6602AEC0493 for ; Fri, 7 Apr 2006 06:57:32 -0700 (PDT) Message-ID: <11879061.1144425562492.JavaMail.tomcat@stilton> Date: Fri, 7 Apr 2006 08:59:22 -0700 (PDT) From: "Niall Stapley (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: Innocent X-DSPAM-Processed: Fri Apr 7 06:57:33 2006 X-DSPAM-Confidence: 0.6267 X-DSPAM-Probability: 0.0000 X-DSPAM-Signature: 44366fcd195831804284693 X-DSPAM-Factors: 27, to+only, 0.99770, have+things, 0.99617, very+useful, 0.99617, something?, 0.99047, Subject*(AMQ, 0.01000, Received*stilton, 0.01000, Return-Path*, 0.01000, which+would, 0.01000, Received*geronimo.apache.org>+Fri, 0.01000, Received*geronimo.apache.org>+Fri, 0.01000, Date*2006+08, 0.01000, slow+consumers, 0.01000, slow+consumers, 0.01000, g+for, 0.01000, Url*org/jira//secure/Administrators, 0.01000, The+data, 0.01000, New+Feature, 0.01000, Date*08+59, 0.01000, 394, 0.01000, 394, 0.01000, Reporter+james, 0.01000, Subject*add, 0.01000, only+allow, 0.01000, state+and, 0.01000, Url*org/jira//browse/AMQ, 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_35905 ] Niall Stapley commented on AMQ-394: ----------------------------------- We have a similar scenario which would make this feature very useful. There is a single publisher producing many small messages (to topics) to many (sometimes slow or even stalled) subscribers. The data in the messages is useful only for about 10 seconds, so we try to use topicPublisher.setTimeToLive(10000) to avoid flow control or broker buffer problems. The messages transmit the latest state and do so regularly so it is not important if delivery of older messages is unreliable for slow consumers, as long as the producer remain unimpeded. > 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