Hello,
I'm currently running Camel 2.12.2, upgraded from camel 2.11.3. Both
Are running inside Karaf 2.3.3. I have some routes using the same
FileIdempotentRepository but they don't seem to work. I haven't
investigated very thoroughly yet,
My routes look like this:
----
from("file:///vftp?recursive=true" +
"&delay=5s" +
"&antInclude=**/in/*.xml,**/in/*.csv" +
"&antFilterCaseSensitive=false" +
"&readLock=changed" +
"&readLockCheckInterval=5s" +
"&readLockTimeout=60s")
.transacted()
.log("Processing ${file:name} with size ${file:size}. ")
.idempotentConsumer(simple("${file:name}-${file:size}"),
getRepository())
.choice()
.when(isFromClient)
.to(processFirstClient)
.otherwise()
.to(processSecondClient)
.end();
And my repository is configured in blueprint using:
<bean id="fileStore"
class="org.apache.camel.processor.idempotent.FileIdempotentRepository">
<property name="fileStore" value="data/idempotent-file-store.dat"/>
<property name="maxFileStoreSize" value="5120000"/>
</bean>
However, I get the following:
$ grep -n 2014011743097_12.xml idempotent-file-store.dat
1816:in/2014011743097_12.xml-4037
7131:in/2014011743097_12.xml-4037
8678:in/2014011743097_12.xml-4037
Any ideas on where to look?
Thanks,
--
Ioan Eugen Stan
0720 898 747