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é

Reply via email to