uot;)
> .filter()
> .to("myprocess")
> .end()
> .to("mock.out");
>
>
> ----
> If you reply to this email, your message will be added to the discussion
> below:
> http://camel.465427.n5.nabble.
o("mock.out");
--
View this message in context:
http://camel.465427.n5.nabble.com/parallelProcessing-with-multicast-tp5765146p5765154.html
Sent from the Camel - Users mailing list archive at Nabble.com.
t;).filter(body.isEqualTo(0)).
process(new Processor {
override def process(exchange: Exchange): Unit = {
(1 to 10).foreach(x => {
Thread.sleep(100)
println("even")
})
}
}
).
uot;direct:even").filter(body.isEqualTo(0)).
> process(new Processor {
> override def process(exchange: Exchange): Unit = {
> Thread.sleep(1000)
> }
> }
> ).
> to("mock:outp
")
}
}
--
View this message in context:
http://camel.465427.n5.nabble.com/parallelProcessing-with-multicast-tp5765146p5765149.html
Sent from the Camel - Users mailing list archive at Nabble.com.
ock:output")
> }
> }
>
> //.
> val producer = camelContext.createProducerTemplate()
> List(0, 1, 0, 1, 0, 1, 0, 1, 0, 1).foreach(x =>
> producer.sendBody("direct:input", x))
>
>
>
>
> --
> View this message in context:
&g
r.sendBody("direct:input", x))
--
View this message in context:
http://camel.465427.n5.nabble.com/parallelProcessing-with-multicast-tp5765146.html
Sent from the Camel - Users mailing list archive at Nabble.com.
