I'm using the released version 2.8.0
Below is a code snippet of what i'm currently doing :
String uri = buildFullUri(baseUrl, fileName);
GenericFileEndpoint endpoint = (GenericFileEndpoint)
exchange.getContext().getEndpoint(uri);
PollingConsumer consumer = endpoint.createPollingConsumer();
consumer.start();
Exchange result = consumer.receive(DEFAULT_TIMEOUT);
consumer.stop();
if (result == null) {
throw new IllegalStateException("Requested resource [" + fileName + "]
has not been found.");
}
GenericFile body = result.getIn().getBody(GenericFile.class);
endpoint.getInProgressRepository().remove(body.getAbsoluteFilePath());
--
View this message in context:
http://camel.465427.n5.nabble.com/inProgressRepository-not-cleaned-in-GenericFileEndpoint-tp4722713p4722880.html
Sent from the Camel - Users mailing list archive at Nabble.com.
