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 : san...@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.
