1234567891011121314151617181920212223242526272829303132333435363738 |
- package com.sagacloud.route;
- import com.sagacloud.cache.ProPasCache;
- import com.sagacloud.utils.PropUtil;
- import org.apache.camel.builder.RouteBuilder;
- import javax.ws.rs.core.MediaType;
- import java.util.ArrayList;
- import java.util.List;
- /**
- * Created by wo on 5/24/17.
- */
- public class InitEnvRoute extends RouteBuilder {
- public static String dataPlatform = PropUtil.getProperty("dataPlatform.baseUrl");
- public static String venders = PropUtil.getProperty("venders.baseUrl");
- @Override
- public void configure() throws Exception {
- fromF("timer://simpleTimer?period=1m").to("direct:syn");
- from("direct:syn")
- .to(dataPlatform + "/mng/project/query?bridgeEndpoint=true&secret=A123456")
- .process(exchange -> {
- ProPasCache.syncProject(exchange.getIn().getBody(String.class));
- })
- .to(venders+"/auxiliary/vender/query")
- .process(exchange -> {
- ProPasCache.syncVender(exchange.getIn().getBody(String.class));
- });
- rest("/syn")
- .get()
- .to("direct:syn");
- }
- }
|