CollectQuartzRoute.java 504 B

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