public void start()

in dynamic-router-eip/src/main/java/org/apache/camel/example/springboot/numbers/service/NumbersService.java [115:125]

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

    public void start() throws InterruptedException {
        LOG.info("Subscribing {} participants", participants.size());
        participants.forEach(RoutingParticipant::subscribe);
        final StopWatch watch = new StopWatch();
        LOG.info("Sending {} messages to the dynamic router: {}", numberFormat.format(numberOfMessages), getStartUri());
        CompletableFuture.runAsync(this::sendMessages, Executors.newSingleThreadExecutor());
        if (!countDownLatch.await(1, MINUTES)) {
            LOG.warn("Statistics may be inaccurate, since the operation timed out");
        }
        LOG.info(resultsService.getStatistics(watch));
    }