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é