ExampleCamelExistRoute.java

/**
 * listen to topic queue
 * -- on incoming message
 * --- split message into program fragments using xpath
 * ---- extract the id from the program
 * ---- write a program document to the xml store 
 */

from("activemq:topic:incomingVPROGuide")
  .splitter(vpro.xpath("//vpro:program"))
  .setHeader(FileComponent.HEADER_FILE_NAME, vpro.xpath("//vpro:program/@id", String.class))
  .process(sanitize(FileComponent.HEADER_FILE_NAME))
  .to("xmldb:/programs");