Return-Path: 
 <users-return-27181-apmail-camel-users-archive=camel.apache.org@camel.apache.org>
X-Original-To: apmail-camel-users-archive@www.apache.org
Delivered-To: apmail-camel-users-archive@www.apache.org
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by minotaur.apache.org (Postfix) with SMTP id 68BCF9637
	for <apmail-camel-users-archive@www.apache.org>;
 Mon, 27 Feb 2012 11:20:49 +0000 (UTC)
Received: (qmail 48757 invoked by uid 500); 27 Feb 2012 11:20:49 -0000
Delivered-To: apmail-camel-users-archive@camel.apache.org
Received: (qmail 48720 invoked by uid 500); 27 Feb 2012 11:20:49 -0000
Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:users-help@camel.apache.org>
List-Unsubscribe: <mailto:users-unsubscribe@camel.apache.org>
List-Post: <mailto:users@camel.apache.org>
List-Id: <users.camel.apache.org>
Reply-To: users@camel.apache.org
Delivered-To: mailing list users@camel.apache.org
Received: (qmail 48711 invoked by uid 99); 27 Feb 2012 11:20:48 -0000
Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230)
    by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 27 Feb 2012 11:20:48 +0000
X-ASF-Spam-Status: No, hits=2.2 required=5.0
	tests=FREEMAIL_ENVFROM_END_DIGIT,SPF_NEUTRAL,URI_HEX
X-Spam-Check-By: apache.org
Received-SPF: neutral (nike.apache.org: 216.139.236.26 is neither permitted
 nor denied by domain of sanre6@gmail.com)
Received: from [216.139.236.26] (HELO sam.nabble.com) (216.139.236.26)
    by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 27 Feb 2012 11:20:42 +0000
Received: from [192.168.236.26] (helo=sam.nabble.com)
	by sam.nabble.com with esmtp (Exim 4.72)
	(envelope-from <sanre6@gmail.com>)
	id 1S1ycv-0004YL-FX
	for users@camel.apache.org; Mon, 27 Feb 2012 03:20:21 -0800
Date: Mon, 27 Feb 2012 03:20:21 -0800 (PST)
From: "sanketh.reddy" <sanre6@gmail.com>
To: users@camel.apache.org
Message-ID: <1330341621475-5518658.post@n5.nabble.com>
Subject: How to remove message's from a vm endpoint ?
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit
X-Virus-Checked: Checked by ClamAV on apache.org

Hi,

i have a scenario where message's are getting accumulated in a vm endpoint
due to slow consumers . I want to remove this old message's and process only
new one's at regular intervals on reaching a threshold .How can i do this ?

i have recreated the scenario using a simple route like below , where i have
made consumers intentionally slow such that message accumulation happens

	<route id="route1">
	<from uri="timer://Timer?period=1000" />
	<to uri="bean:producer?method=send" />
	<to uri="vm:simpleEp" />
	</route>

	<route id="route2">
	<from uri="simpleEp" />
	<to uri="bean:consumer?method=recv" />
	</route>

i have tried getting the endpoint and starting/stopping it such that it will
delete the pending message's like below code but its not working

ApplicationContextProvider.getCamelContext().getEndpoint("vm:vm:simpleEp").stop()/start()

Is there a way to do this from camelcontext ? if not is there a jmx
alternative ?

Thanks

sanre6

-----
thanks
sanketh
mail : sanre6@gmail.com
--
View this message in context: http://camel.465427.n5.nabble.com/How-to-remove-message-s-from-a-vm-endpoint-tp5518658p5518658.html
Sent from the Camel - Users mailing list archive at Nabble.com.