from("direct:inbound")
  .multicast().parallelProcessing().to("direct:a", "direct:b");

//message a
from("direct:a").processRef("processor_a").to("validator:a.xsd")
  .multicast().parallelProcessing().to("jms:q1", "jms:q2");

//message b
from("direct:b").processRef("processor_b").to("validator:b.xsd")
  .multicast().parallelProcessing().to("jms:q3", "jms:q4");

I only want to send the messages a and b to their JMS endpoints IF both A
and B has been validated without problems, if not the message should be sent
to the error queue.
The processors are transformers and will transform the messages to different
xsd versions



--
View this message in context: 
http://camel.465427.n5.nabble.com/Handling-splitting-and-error-handling-tp5765748.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Reply via email to