Camel csv bindy, splitter and aggregator


		from(sourceFtpUrl)//probably do archiving here??
						"this part is consuming one csv file of many rows of records")
				.unmarshal(bindy)//this is part to unmarshal to list of objects
				.split(body(), new SomeAggregator())//split the list, pass each bean to someBeanToProcessEachObject, then Aggregarte using SomeAggregator to aggregate each new object into old list
					.beanRef("someBeanToProcessEachObject", "process")
						.beanRef("someProcess", "process")//Split again, which now each object is an already aggregrated object
				.log(LoggingLevel.INFO, getClass().getName(),
						"All Processed");

Leave a Reply

Fill in your details below or click an icon to log in: Logo

You are commenting using your account. Log Out /  Change )

Twitter picture

You are commenting using your Twitter account. Log Out /  Change )

Facebook photo

You are commenting using your Facebook account. Log Out /  Change )

Connecting to %s