QlcRouteBulider.java 1.1 KB

1234567891011121314151617181920212223
  1. package qlc.route;
  2. import org.apache.camel.Exchange;
  3. import org.apache.camel.builder.RouteBuilder;
  4. import org.springframework.stereotype.Component;
  5. import qlc.processor.Processor1;
  6. import qlc.processor.Processor2;
  7. /**
  8. * Created by lingfeng on 2016/7/25.
  9. */
  10. public class QlcRouteBulider extends RouteBuilder {
  11. @Override
  12. public void configure() throws Exception {
  13. from("jetty:http4://172.17.110.178:9088/qlc").routeId("qlc")
  14. .process(new Processor1()).setHeader(Exchange.HTTP_METHOD, constant("POST")).log("servers: 3,code: queryUserInfo,order: 1")
  15. .to("http4://172.19.103.89:8088/api/v1.0/qlc/queryUserInfo").log("servers: 3,code: queryUserInfo,order: 1")
  16. .process(new Processor2()).setHeader(Exchange.HTTP_METHOD, constant("POST")).log("servers: 3,code: patientInformation,order: 1")
  17. .to("http4://172.19.103.89:8088/api/v1.0/qlc/patientInformation").log("servers: 3,code: patientInformation,order: 1")
  18. .process(new Processor2()).setHeader(Exchange.HTTP_METHOD, constant("POST")).to("stream:out"); // 2. 为路由配置组件或终端节点.
  19. }
  20. }