public String start()

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

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

    public String start(int limit) throws InterruptedException {
        resultsService.resetStatistics();
        LOG.info("Subscribing {} participants", participants.size());
        participants.forEach(RoutingParticipant::subscribe);
        countDownLatch = new CountDownLatch(1);
        final StopWatch watch = new StopWatch();
        LOG.info("Sending {} messages to the dynamic router: {}", limit, getStartUri());
        Mono<Integer> msgFlux = sendMessages(limit);
        msgFlux.subscribe();
        if (!countDownLatch.await(1, MINUTES)) {
            LOG.warn("Statistics may be inaccurate, since the operation timed out");
        }
        return resultsService.getStatistics(watch, limit);
    }