public boolean launch()

in aggregate-dist/src/main/java/org/apache/camel/example/Application.java [78:97]

• 15 lines of code
• 3 McCabe index (conditional complexity)

    public boolean launch() {
        try {
            // init
            IntStream.rangeClosed(1, END).forEach(inputQueue::add);

            // test
            for (int i = 0; i < THREADS; i++) {
                executor.execute(this::startCamel);
            }

            // wait
            latch.await();
            stop();
            return true;
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            LOG.error("The test has been interrupted", e);
        }
        return false;
    }