我需要在集群环境中完全实现idempotentRepository。 我目前的实现如下,它是为实现idempotentRepository引起:java.lang.IllegalArgumentException:在使用readLock = idempotent时必须配置IdempotentRepository
<route id="request" >
<from uri="file:someFolderLocation?readLock=idempotent&readLockRemoveOnCommit=true"/>
<to uri="file: someOtherFolderLocation "/>
我使用骆驼在集群环境中抛出错误,并希望使用 readlock我的文件消费者端点。唯一的群集安全的readlock 是幂等性的readlock,但是这需要在文件uri上设置一个 idempotentRepository。
Caused by: java.lang.IllegalArgumentException: IdempotentRepository must be configured when using readLock=idempotent
at org.apache.camel.component.file.GenericFileEndpoint.doStart(GenericFileEndpoint.java:1328)
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
at org.apache.camel.impl.DefaultCamelContext.startService(DefaultCamelContext.java:3269)
at org.apache.camel.impl.DefaultCamelContext.doAddService(DefaultCamelContext.java:1243)
at org.apache.camel.impl.DefaultCamelContext.addService(DefaultCamelContext.java:1204)
at org.apache.camel.impl.DefaultCamelContext.addService(DefaultCamelContext.java:1200)
at org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:584)
... 40 more
请指点。
感谢您的帮助! –