123456789101112 |
- package collect.route;
- import collect.processor.CollectProcessor0;
- import org.apache.camel.Exchange;
- import org.apache.camel.builder.RouteBuilder;
- public class CollectQuartzRoute extends RouteBuilder {
- public void configure() throws Exception {
- from("quartz://myGroup/myTimerName?cron=0/3 * * * * ?").routeId("routeId").process(new CollectProcessor0())
- .setHeader(Exchange.HTTP_METHOD, constant("POST")).to("http4://localhost:8088/crawler/collect").to("stream:out");
- }
- }
|