Scenario: Using cSplitter to split a message and aggregate replies from
sub-messages

This scenario applies only to a Talend solution with ESB.

In this scenario, we will use the cSplitter component
to split a message and aggregate the replies from sub-messages.

A predefined Java Bean, AppendAggregator will be called to as the
strategy to aggregate the replies from sub-messages. For more information about creating
and using Java beans, see
Talend Studio User Guide.

package beans;
import org.apache.camel.Exchange;
import org.apache.camel.processor.aggregate.AggregationStrategy;

public class AppendAggregator implements AggregationStrategy {

	public Exchange aggregate(Exchange oldEx, Exchange newEx) {
		if(oldEx==null){
			return newEx;
		}
		String oldBody = oldEx.getIn().getBody(String.class);
		String newBody = newEx.getIn().getBody(String.class);
		newEx.getIn().setBody(oldBody + "
" + newBody);
		return newEx;
	}
}

package beans;

import org.apache.camel.Exchange;

import org.apache.camel.processor.aggregate.AggregationStrategy;

public class AppendAggregator implements AggregationStrategy {

public Exchange aggregate(Exchange oldEx, Exchange newEx) {

if(oldEx==null){

return newEx;

}

String oldBody = oldEx.getIn().getBody(String.class);

String newBody = newEx.getIn().getBody(String.class);

newEx.getIn().setBody(oldBody + "

" + newBody);

return newEx;

}

Document get from Talend https://help.talend.com

Thank you for watching.

Docs 6.x

0 Comments

Inline Feedbacks

View all comments

Scenario: Using cSplitter to split a message and aggregate replies from sub-messages – Docs for ESB 6.x

Scenario: Using cSplitter to split a message and aggregate replies from
sub-messages

My Website Links

Tags