public void configure()

in resume-api/resume-api-fileset-clusterized/src/main/java/org/apache/camel/example/resume/fileset/clusterized/strategies/ClusterizedLargeDirectoryRouteBuilder.java [51:66]

• 14 lines of code
• 1 McCabe index (conditional complexity)

    public void configure() {
        final KafkaResumeStrategyConfigurationBuilder defaultKafkaResumeStrategyConfigurationBuilder = KafkaUtil
                .getDefaultKafkaResumeStrategyConfigurationBuilder()
                .withResumeCache(new CaffeineCache<>(10000));

        from("timer:heartbeat?period=10000")
                .routeId("heartbeat")
                .log("HeartBeat route (timer) ...");

        from("master:resume-ns:file:{{input.dir}}?noop=true&recursive=true&repeatCount=1")
                .resumable()
                .configuration(defaultKafkaResumeStrategyConfigurationBuilder)
                .routeId("clustered")
                .process(this::process)
                .to("file:{{output.dir}}");
    }