Newbie: how to test?

hello, I started looking into Camel a few days ago and was wondering how to test... I define my camelContext through Spring, with the route I want to use http://camel.apache.org/schema/spring";> my subscriptionRoute is defined like this: from("jms:queue:subscription"). where jms is

No hit during Multicast

hello, we are using multicast to route messages to a number of endpoints. The endpoints contain filter method method to decide if the enpoint is going to process the message or not. Is there a way to tell if no endpoints have processed the message? In that case, we would like to put the message in

Re: No hit during Multicast

I use the filter EIP as described in previous post, but I can not seem to find the CamelFilterMatched property anywhere. How do I obtain it? The only properties I see are the three listed below. Should the CamelFilterMatched be in the same list? I'm using Camel 2.9.0 http://camel.465427.n5.nabble.

MulticastDefinition.choice() - does it make any sense?

so you can do a MulticastDefinition.choice() since choice() is inherited from ProcessorDefinition but does it make any sense? when I try to use it, I get java.lang.ClassCastException: org.apache.camel.model.MulticastDefinition cannot be cast to org.apache.camel.model.ChoiceDefinition -- View thi

Re: No hit during Multicast

Claus, could you please enlighten me on this? When using the multicast definition above, the Exchange is not forwarded to the destination (.bean...) if the filter Predicate is false. I.e. I do not have a handle to the Exchange anymore, and I can not check any headers. I've tried to use multicast()

Re: No hit during Multicast

yes, I see that my description of the filter is lacking. It's actually a loop like this, where the producers contain filter-methods: MulticastDefinition multicastDefinition = route.multicast().onPrepare(new DocumentDeepClone()); for (Producer producer : producers) { multicastDefinition .filter

Re: No hit during Multicast

thanks, Claus, I'm slowly getting there... I think my problem might be more fundamental. If I try to put the AggregationStrategy into the multicast, I am still not able to get a hold of the Exchange. All "filter"s turn out false => no .aggregate is reached. How do I get a handle on that Exchange a

Re: No hit during Multicast

great, thanks. Would the AggreagtionStrategy work if I add parallelProcessing to the MulticastDefinition as well? Like this MulticastDefinition multicastDefinition = route.multicast().*parallelProcessing().timeout(1).*onPrepare(new DocumentDeepClone()); -- View this message in context: htt

Re: No hit during Multicast

this is turning into a farce and I might end up being the stupidest kid on earth :-) Anyway, when aggregating, I do not seem to be able to fetch relevant data from neither the oldExchange nor the newExchange. I am not able to see any Exchange.TO_ENPOINT, and all headers I set within the bean or fi

copy of Exchange during Multicast

according to http://camel.apache.org/multicast.html http://camel.apache.org/multicast.html , multicast will copy the source Exchange and multicast each copy. I.e. changes done to the Exchange remains local to the multicast recipient. Is there a way to make changes done to the header visible in fur

Re: copy of Exchange during Multicast

Thanks, Henryk, I really appreciate your answer. I can see that the FilterProcessor do exchange.setProperty(Exchange.FILTER_MATCHED, matches); and I also see that the GroupedExchangeAggregationStrategy puts the Exchange in it's list of answer.properties. I also set headers/properties myself (in