split.java

// camel-k: language=java

import org.apache.camel.builder.RouteBuilder;

public class split extends RouteBuilder {

    @Override
    public void configure() throws Exception {

        // Write your routes here, for example:
        from("timer:java?period={{time:1000}}")
            .setBody()
                .simple("A,B,C,D,E")
            .log("Before split ${threadName}")
            .split(body()).parallelProcessing().synchronous()
                .log("Inside ${threadName}: ${body}")
            .end()
            .log("Done split ${threadName}");
    }
}