InitEnvRoute.java 1.1 KB

1234567891011121314151617181920212223242526272829303132333435363738
  1. package com.sagacloud.route;
  2. import com.sagacloud.cache.ProPasCache;
  3. import com.sagacloud.utils.PropUtil;
  4. import org.apache.camel.builder.RouteBuilder;
  5. import javax.ws.rs.core.MediaType;
  6. import java.util.ArrayList;
  7. import java.util.List;
  8. /**
  9. * Created by wo on 5/24/17.
  10. */
  11. public class InitEnvRoute extends RouteBuilder {
  12. public static String dataPlatform = PropUtil.getProperty("dataPlatform.baseUrl");
  13. public static String venders = PropUtil.getProperty("venders.baseUrl");
  14. @Override
  15. public void configure() throws Exception {
  16. fromF("timer://simpleTimer?period=1m").to("direct:syn");
  17. from("direct:syn")
  18. .to(dataPlatform + "/mng/project/query?bridgeEndpoint=true&secret=A123456")
  19. .process(exchange -> {
  20. ProPasCache.syncProject(exchange.getIn().getBody(String.class));
  21. })
  22. .to(venders+"/auxiliary/vender/query")
  23. .process(exchange -> {
  24. ProPasCache.syncVender(exchange.getIn().getBody(String.class));
  25. });
  26. rest("/syn")
  27. .get()
  28. .to("direct:syn");
  29. }
  30. }