private void addResumeInfo()

in resume-api/resume-api-cassandraql/src/main/java/org/apache/camel/example/resume/cassandra/main/CassandraRoute.java [63:73]

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

    private void addResumeInfo(Exchange exchange) {
        ExampleEntry bodyEntry = exchange.getMessage().getBody(ExampleEntry.class);

        LOG.info("Received record number: {}", bodyEntry.getNumber());
        exchange.getMessage().setHeader(Exchange.OFFSET, Resumables.of(bodyEntry.getId().toString(), bodyEntry.getId().toString()));
        if (latch.getCount() == 1) {
            exchange.setRouteStop(true);
        }

        latch.countDown();
    }