有 Java 编程相关的问题?

你可以在下面搜索框中键入要查询的问题!

java如何在camel文件组件配置中结合readLockCheckInterval和maxMessagesPerPoll?

我们面临的问题是,camel文件组件readLockCheckInterval允许一次处理单个文件,而对于下一个文件camel lock,它将等待readLockCheckInterval时间。我们有10000个或更多的文件需要并行处理。我想使用maxMessagesPerPoll属性来访问每次轮询的多个文件,但要使用readLockCheckInterval,因为如果文件仍在复制,camel会释放文件锁。如果有其他方法来解决上述问题,那将是非常有帮助的。我正在尝试的路由配置如下:

来自(“inputFolder?recursive=true&;moveFailed=。error&;readLock=changed&;readLockCheckInterval=5000&;readLockTimeout=20000&;maxMessagesPerPoll=5&;maxMessagesPerPoll=true”)


共 (0) 个答案