CamelTest.java

public void configure() {
                from("direct:products").
                        from("direct:prices").
                        split(xpath("//Skus/Sku|//skus/sku")).
                        setHeader("SkuID", xpath("//Sku/@Id|//sku/@id", String.class)).convertBodyTo(String.class).
                        aggregate(header("SkuID"), new GroupedMessageAggregationStrategy()).completionSize(2).completionTimeout(2000).
                        to("mock:end");
            }