hi,
i want my route to re-consume files after the modified date or the file size
changed.
here is the route:
&moveFailed=.error/${file:name.noext}-${date:now:yyyyMMddHHmmssSSS}.${file:ext}")
.split().tokenize("\n")
.choice()
.when(simple("${property.CamelSplitComplete} ==
true"))
.log("set or update alias")
.to("direct:setAlias")
.when(simple("${property.CamelSplitIndex} > 0"))
.unmarshal(csv)
.to("direct:doMapping")
.otherwise()
.log("Loading new Feed-File")
.end()
;
from("direct:doMapping")
.process(new Mapping()) // mapping processor sets new index name
for the elasticsearch index
.to("elasticsearch://elasticsearch?operation=INDEX&indexName=data_test&indexType=es_t_data_product&ip=192.168.101.139&port=9300");
from("direct:setAlias")
.process(new SetAlias()) // mapping processor sets new index
name
for the elasticsearch index
.log("Done setting or updating new Alias...");
}
this works super cool if i copy in new files. route will consume and all
works fine.
but if i now change a file. copy it in with a new filesize or filedate the
route wont run again on the file automaticly.
any ideas?
--
View this message in context:
http://camel.465427.n5.nabble.com/consume-existing-already-consumed-files-on-modifed-date-or-size-tp5743867.html
Sent from the Camel - Users mailing list archive at Nabble.com.