camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "sanketh.reddy" <san...@gmail.com>
Subject How to remove message's from a vm endpoint ?
Date Mon, 27 Feb 2012 11:20:21 GMT
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.

Mime
View raw message