camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Christophe Pache <chpa...@gmail.com>
Subject Re: parallelProcessing with multicast
Date Wed, 01 Apr 2015 12:38:01 GMT
Thanks Claus for your answer! I did test but did not succeed into making it
work as I wanted to (change the order of received message). Following your
advice, I've just added the streaming configuration to the multicast eip
such as following, is that correct?

      val croute = new org.apache.camel.builder.RouteBuilder {
        override def configure(): Unit = {
          from("direct:input").multicast().parallelProcessing().streaming().
            to("direct:even", "direct:odd").end()

          from("direct:odd").filter(body.isEqualTo(1)).to("mock:output")

          from("direct:even").filter(body.isEqualTo(0)).
            process(new Processor {
            override def process(exchange: Exchange): Unit = {
              Thread.sleep(1000)
              }
            }
          ).
            to("mock:output")
        }
      }



--
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.

Mime
View raw message