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

Reply via email to