Hi

You need to use the parallelProcessing option as documented on the
wiki pages for those EIPs.


On Mon, Jan 16, 2012 at 11:20 AM, Hervé BARRAULT
<[email protected]> wrote:
> Hi,
> I have a question concerning camel camel-core (2.4.0.fuse-00-00) ,
> activemq camel activemq-camel (5.4.0.fuse-00-00) and activemq
> activemq-core (5.4.0.fuse-00-00).
>
> I am trying to use multicast.
>
> I had a route :
>
> from(sourceUri_)
>            .errorHandler(noErrorHandler())
>            .policy(getTracePolicy())
>            .policy(getErrorReportingPolicy())
>            .process(myProcessor_)
>            .recipientList(header(TARGET_HEADER));
>
> But when sending to n target queues, we noticed that the behavior is
> sequential (normal).
>
> Now we are trying to use multicast :
> from(sourceUri_)
>            .errorHandler(noErrorHandler())
>            .policy(getTracePolicy())
>            .policy(getErrorReportingPolicy())
>            .process(myProcessor_)
>            .multicast()
>            .parallelProcessing()
>            .recipientList(header(TARGET_HEADER));
>
>
> In this case the message is correctly send to the expected queues (in
> my test 2) but only one queue is consumed.
> For information the processor send itself a generated message in
> another queue, and we are using one way.
>
> Is the right method to use multicast ? Is there something else to do ?
>
> Thanks for answers.
>
> Regards
> Hervé



-- 
Claus Ibsen
-----------------
FuseSource
Email: [email protected]
Web: http://fusesource.com
Twitter: davsclaus, fusenews
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/

Reply via email to