SpringIntegrationTest.java

 @Test
    public void productSplitter() {
        CamelContext context = new DefaultCamelContext();
        try {
            context.addRoutes(new RouteBuilder() {
                @Override
                public void configure() {
                    from("file:src/test/resources/messages/products.xml").
                            split(xpath("//Skus/Sku")).
                            setHeader("SkuID", xpath("//Sku/Id")).convertBodyTo(String.class).to("direct:end");
                }
            });
        } catch (Exception e) {
            e.printStackTrace();
        }

        MockEndpoint resultEndpoint = context.resolveEndpoint("mock:foo", MockEndpoint.class);
        resultEndpoint.setAssertPeriod(5000);
    }