public void doWarmUp()

in dynamic-router-eip/dynamic-router-eip-stack/main-router/src/main/java/org/apache/camel/example/springboot/numbers/mainrouter/service/WarmUpService.java [47:62]

16 lines of code
1 McCabe index (conditional complexity)


    public void doWarmUp() {
        LOG.info("Running warm-up...");
        Flux.range(1, 1000000)
                .flatMap(n -> Mono.just(n)
                        .subscribeOn(Schedulers.boundedElastic())
                        .map(String::valueOf)
                        .doOnNext(ns -> producerTemplate.sendBodyAndHeaders(ENDPOINT_DIRECT_COMMAND, 1,
                                Map.of(HEADER_COMMAND, COMMAND_PROCESS_NUMBER,
                                        HEADER_NUMBER, ns))))
                .doFinally(x -> {
                    LOG.info("Warm-up finished");
                    Message<Events> message = MessageBuilder.withPayload(INITIALIZATION_COMPLETE).build();
                    eventPublisher.publishEvent(new StateMachineEvent(this, message));
                })
                .subscribe();
    }