problem in recipientList with onPrepareRef

[ABouchama <ti...@yahoo.Fr>]

Hello,

The problem: we send a message the queue OUT, the message should be sent 2
times to the queue A, and 1 to the queue B, and we should have the following
result:

1. Msg = should be in the queue A, with header invoked=1
2. Msg = should be in the queue B, with header invoked=2
3. Msg = should be in the queue A, with header invoked=3

But we have this :

1. Msg = should be in the queue A, with header invoked=3
2. Msg = should be in the queue B, with header invoked=2
3. Msg = should be in the queue A, with header invoked=3

We use the following route:

<route id="Sending" errorHandlerRef="myDeadLetterChannel">
	<from uri="activemq:queue:OUT" />
	<setHeader headerName="recipients">
		<simple>activemq://queue:A,activemq://queue:B,activemq://queue:A</simple>
	</setHeader>
	<recipientList parallelProcessing="true" streaming="true"
onPrepareRef="recipientListOnPrepare">
       		<header>recipients</header>
	</recipientList>
</route>

package com.company;

import org.apache.camel.Exchange;
import org.apache.camel.Processor;

public class recipientListOnPrepare implements Processor {
	public void process(Exchange exchange) throws Exception {
		String recipients = (String) exchange.getIn().getHeader("recipients");
		String toEndpoint = (String) exchange.getProperty(Exchange.TO_ENDPOINT);

		String[] Recipients = recipients.split(",");

		for (int i = 0; i < recipients.length; i++) {
			if (toEndpoint.equalsIgnoreCase(recipients[i])) {
				exchange.getIn().setHeader("invoked", i);
			}

		}

	}

}

Thanks in advance,

Regards



--
View this message in context: http://camel.465427.n5.nabble.com/problem-in-recipientList-with-onPrepareRef-tp5746151.html
Sent from the Camel - Users mailing list archive at Nabble.com.