package camel.terminal.crawler.route;

import camel.terminal.crawler.processor.Aggregate;
import camel.terminal.crawler.processor.AggregateProcessor;
import camel.terminal.crawler.processor.HttpProcessor;
import camel.terminal.crawler.processor.Split;
import org.apache.camel.builder.RouteBuilder;

/**
 * Created by lingfeng on 2016/7/25.
 */
public class RouteBulider1 extends RouteBuilder {

    public void configure() throws Exception {
        from("quartz://myGroup/myTimerName?cron=0/5 * * * * ? ").routeId("list")
                .to("http://localhost:9999/list")
                .split().method(Split.class, "splitJsonArray")
                .process(new HttpProcessor("str")).to("http://localhost:9999/str")
                .process(new AggregateProcessor("key1"))
                .aggregate(header("test_correlation_key"), new Aggregate()).completionSize(3).to("stream:out");

    }
}