FileEnrichRoute.java

class FileEnrichRoute extends RouteBuilder {

	@Override
	public void configure() throws Exception {
		from("file:folder1").pollEnrich("file:folder2", new AggregationStrategy() {

			public Exchange aggregate(Exchange original, Exchange resource) {
				String originalBody = original.getIn().getBody(String.class);
				String resourceBody = resource.getIn().getBody(String.class);

				original.getIn().setBody(originalBody + " " + resourceBody);

				return original;
			}
		}).log("Body: ${body}");
	}

}