Hello, I'm working with some service units from ServiceMix and I created some
thing like that:

JMS Consumer -> XPath Splitter \
                                                Pipeline <-> JSR181
JMS Provider    <-  Aggregator    /

When I recive information from JSR181 across Pipeline aggregator can't
aggreage them together - there is error answer like this:
error: java.lang.IllegalArgumentException: Could not retrieve
correlation id for incoming exchange

configuration from eip:
<eip:pipeline service="client:Pipeline" endpoint="pfc">
       <eip:transformer>
       <eip:exchange-target service="client:clientServiceJSR"
endpoint="soap"/>
   </eip:transformer>
   <eip:target>
           <eip:exchange-target service="client:aggregator"
endpoint="aggregator"/>
   </eip:target>
  </eip:pipeline>

  <eip:xpath-splitter service="client:xpathSplitter"
endpoint="xpath" xpath="/clients/*">
   <eip:target>
     <eip:exchange-target service="client:Pipeline" endpoint="pfc" />
   </eip:target>
  </eip:xpath-splitter>

  <eip:split-aggregator service="client:aggregator" endpoint="aggregator">
   <eip:target>
     <eip:exchange-target
service="client:clientServiceJMSSOAPProvider"
endpoint="clientServiceJMSSOAPProvider"/>
   </eip:target>
  </eip:split-aggregator>
and

configuration from jsr181:
<jsr181:endpoint service="client:clientServiceJSR"
style="document" endpoint="jsr"
pojoClass="esbtoolkit.clientImpl" />

Reply via email to