Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@camel.apache.org
Received-SPF: softfail (nike.apache.org: transitioning domain of
 tanteanni@hotmail.com does not designate 216.139.236.26 as permitted sender)
Date: Wed, 2 Jul 2014 05:02:17 -0700 (PDT)
From: dermoritz <tanteanni@hotmail.com>
To: users@camel.apache.org
Message-ID: <1404302537838-5753205.post@n5.nabble.com>
Subject: parallelProcessing seems to change semantic of route
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit

i defined a route in java:

                RouteDefinition rtdmProcess =
from(cepOutputWindow).process(rtdmProcessor);
                MulticastDefinition multicast = rtdmProcess.multicast();
//.parallelProcessing() not working
                log.info("Configuring route from cep window " +
cepOutputWindow + " to " + rtdmUrl
                         + " with following events: ");
                // loop over event names to use same data for every target
event
                // and send it to rtdm
                for (String eventName : rtdmTargetEvents) {
                    //CxfEndpoint cxf = new CxfEndpoint(rtdmUrl, new
CxfComponent(this.getContext()));
                    //cxf.setServiceClass(EventPortType.class);
                    String cxf = "cxf:" + rtdmUrl + "?serviceClass=" +
EventPortType.class.getCanonicalName();
                   
multicast.process(rtdmSetNameFactory.get(eventName)).to(cxf);
                    log.info(eventName + ",");
                }
                multicast.end().process(handleRtdmAnswer);
                rtdmProcess.setId(Routes.RouteIds.cepToRtdm.name() +
cepOutputWindow);
                rtdmProcess.autoStartup(true);

this route takes data from "cepOutputWindow" and creates a soap-message from
it. This soap message must be sent to one web-service multiple times but
eache message sent will have one attribute (name - sumething like a
subservice) different (rtdmSetNameFactory.get(eventName)).
This is working as intended. For each exchange put in i get n messages sent
to ws with n different names.

My problem is: as soon as i add .parallelProcessing() (in line 2) i get n
messages sent to name1 and the next n messages sent to name2. So service
with name1 only sees the first n and service with name2 only sees the 2nd
bunch.

What is wrong with my route?


--
View this message in context: http://camel.465427.n5.nabble.com/parallelProcessing-seems-to-change-semantic-of-route-tp5753205.html
Sent from the Camel - Users mailing list archive at Nabble.com.