private void process()

in resume-api/resume-api-common/src/main/java/org/apache/camel/example/resume/strategies/kafka/fileset/LargeDirectoryRouteBuilder.java [52:60]

• 8 lines of code
• 2 McCabe index (conditional complexity)

    private void process(Exchange exchange) throws InterruptedException {
        File path = exchange.getMessage().getHeader("CamelFilePath", File.class);
        LOG.debug("Processing {}", path.getPath());
        exchange.getMessage().setHeader(Exchange.OFFSET, Resumables.of(path.getParentFile(), path));

        if (delay > 0) {
            Thread.sleep(delay);
        }
    }