private void process()

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

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

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

        // Put a delay to simulate slow processing
        try {
            Thread.sleep(100);
        } catch (InterruptedException e) {
            LOG.trace("Interrupted while sleeping", e);
        }
    }