camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dermoritz <>
Subject parallelProcessing seems to change semantic of route
Date Wed, 02 Jul 2014 12:02:17 GMT
i defined a route in java:

                RouteDefinition rtdmProcess =
                MulticastDefinition multicast = rtdmProcess.multicast();
//.parallelProcessing() not working
      "Configuring route from cep window " +
cepOutputWindow + " to " + rtdmUrl
                         + " with following events: ");
                // loop over event names to use same data for every target
                // and send it to rtdm
                for (String eventName : rtdmTargetEvents) {
                    //CxfEndpoint cxf = new CxfEndpoint(rtdmUrl, new
                    String cxf = "cxf:" + rtdmUrl + "?serviceClass=" +
           + ",");
                rtdmProcess.setId( +

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

What is wrong with my route?

View this message in context:
Sent from the Camel - Users mailing list archive at

View raw message