public void configure()

in resume-api/resume-api-common/src/main/java/org/apache/camel/example/resume/strategies/kafka/file/LargeFileRouteBuilder.java [85:106]

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

    public void configure() {
        producerTemplate = getContext().createProducerTemplate();

        final KafkaResumeStrategyConfigurationBuilder defaultKafkaResumeStrategyConfigurationBuilder = KafkaUtil
                .getDefaultKafkaResumeStrategyConfigurationBuilder()
                .withResumeCache(cache);

        from("file:{{input.dir}}?noop=true&fileName={{input.file}}")
                .routeId("largeFileRoute")
                .convertBodyTo(String.class)
                .split(body().tokenize("\n"))
                    .streaming()
                    .stopOnException()
                .resumable()
                    .configuration(defaultKafkaResumeStrategyConfigurationBuilder)
                    .intermittent(true)
                    .process(this::process);

        from("direct:summary")
                .to("file:{{output.dir}}?fileName=summary.txt&fileExist=Append&appendChars=\n");

    }