You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by gn...@apache.org on 2008/02/28 13:31:44 UTC
svn commit: r631941 -
/servicemix/smx3/trunk/deployables/serviceengines/servicemix-eip/src/main/java/org/apache/servicemix/eip/patterns/StaticRecipientList.java
Author: gnodet
Date: Thu Feb 28 04:31:37 2008
New Revision: 631941
URL: http://svn.apache.org/viewvc?rev=631941&view=rev
Log:
SM-1239: EIP StaticRecipientList should set splitter properties in asynchronous mode
Modified:
servicemix/smx3/trunk/deployables/serviceengines/servicemix-eip/src/main/java/org/apache/servicemix/eip/patterns/StaticRecipientList.java
Modified: servicemix/smx3/trunk/deployables/serviceengines/servicemix-eip/src/main/java/org/apache/servicemix/eip/patterns/StaticRecipientList.java
URL: http://svn.apache.org/viewvc/servicemix/smx3/trunk/deployables/serviceengines/servicemix-eip/src/main/java/org/apache/servicemix/eip/patterns/StaticRecipientList.java?rev=631941&r1=631940&r2=631941&view=diff
==============================================================================
--- servicemix/smx3/trunk/deployables/serviceengines/servicemix-eip/src/main/java/org/apache/servicemix/eip/patterns/StaticRecipientList.java (original)
+++ servicemix/smx3/trunk/deployables/serviceengines/servicemix-eip/src/main/java/org/apache/servicemix/eip/patterns/StaticRecipientList.java Thu Feb 28 04:31:37 2008
@@ -159,6 +159,9 @@
for (int i = 0; i < recipients.length; i++) {
MessageExchange me = getExchangeFactory().createExchange(exchange.getPattern());
recipients[i].configureTarget(me, getContext());
+ in.setProperty(RECIPIENT_LIST_COUNT, new Integer(recipients.length));
+ in.setProperty(RECIPIENT_LIST_INDEX, new Integer(i));
+ in.setProperty(RECIPIENT_LIST_CORRID, exchange.getExchangeId());
MessageUtil.transferToIn(in, me);
send(me);
}