public void configure()

in splitter-eip/src/main/java/org/apache/camel/example/spring/boot/SplitterRouter.java [30:103]
50 lines of code
4 McCabe index (conditional complexity)

	public void configure() throws Exception {

		// @formatter:off
		// Example 1 : Simple splitter
		from("direct:splitter")
				// body is of type java.lang.Iterable, java.lang.String or Array
				.split(body())
				.to("mock:a");

		// Example 2 : Splitter with subsequent aggregation
		from("direct:split-aggregate")
					.split(body(), ((oldExchange, newExchange) -> {
						if (oldExchange == null) {
							// this is the first time so no existing aggregated exchange
							return newExchange;
						}

						String body = newExchange.getIn().getBody(String.class);
						String existing = oldExchange.getIn().getBody(String.class);

						oldExchange.getIn().setBody(existing + "+" + body);
						return oldExchange;
					}))
				// Transform after aggregation
				.bean(MyMessageTransformer.class)
				.to("mock:b")
				.end()
			.to("mock:c");

		// Example 3 : Splitter with subsequent aggregation using POJO bean instead of AggregationStrategy implementation
		from("direct:split-aggregate-bean")
				// Aggregation with POJO, no tight coupling to Camel API - better for unit testing
					.split(body(), AggregationStrategies.bean(AggregationStrategyPojo.class))
					// Transformation after aggregation
					.bean(MyMessageTransformer.class)
					.to("mock:d")
				.end()
			.to("mock:e");

		// Example 4 : Splitter with subsequent aggregation failing on exception
		from("direct:split-aggregate-stop-on-exception")
				.split(body(), AggregationStrategies.bean(AggregationStrategyPojo.class))
						// stop processing if exception occurred during process of splitting
						.stopOnException()
						.bean(MyMessageTransformer.class)
					.to("mock:f")
				.end()
			.to("mock:g");

		// Example 5: Splitter with subsequent aggregation on failing on aggregation exception
		from("direct:split-aggregate-stop-on-aggregation-exception")
				// Continuing route processing on exception
				.onException(IllegalArgumentException.class).continued(true).end()
				.split(body(), ((oldExchange, newExchange) -> {
						if (oldExchange == null) {
							// this is the first time so no existing aggregated exchange
							return newExchange;
						}

						String body = newExchange.getIn().getBody(String.class);
						String existing = oldExchange.getIn().getBody(String.class);
						if (body.equals("E")){
							throw new IllegalArgumentException("Error occurred during aggregation");
						}
						oldExchange.getIn().setBody(existing + "+" + body);
						return oldExchange;
					}))
					.bean(MyMessageTransformer.class)
				.to("mock:h")
				.end()
			.to("mock:j");
		// @formatter:on

	}