in resume-api/resume-api-fileset-wal/src/main/java/org/apache/camel/example/resume/fileset/wal/main/MainApp.java [39:57]
public static void main(String... args) throws Exception {
Main main = new Main();
SingleNodeKafkaResumeStrategy resumeStrategy = KafkaUtil.getDefaultStrategy();
final String logFile = System.getProperty("wal.log.file");
final long delay = Long.parseLong(System.getProperty("processing.delay", "0"));
final WriteAheadResumeStrategyConfigurationBuilder configurationBuilder = WriteAheadResumeStrategyConfigurationBuilder
.newBuilder()
.withDelegateResumeStrategy(resumeStrategy)
.withLogFile(new File(logFile));
RouteBuilder routeBuilder = new LargeDirectoryRouteBuilder(configurationBuilder, new CaffeineCache<>(10000), delay);
main.configure().addRoutesBuilder(new CheckRoute());
main.configure().addRoutesBuilder(routeBuilder);
main.run(args);
}