Browse Source

定时任务

Jxing 6 years ago
parent
commit
5c9c8b04b7
1 changed files with 2 additions and 0 deletions
  1. 2 0
      src/main/java/com/sagacloud/route/Route.java

+ 2 - 0
src/main/java/com/sagacloud/route/Route.java

@@ -50,10 +50,12 @@ public class Route extends ExceptionHandlerBaseRoute {
                 .produces(MediaType.APPLICATION_JSON)
                 .produces(MediaType.APPLICATION_JSON)
                 .route()
                 .route()
                 .process(exchange -> {
                 .process(exchange -> {
+
                     String jsonStr = exchange.getIn().getBody(String.class);
                     String jsonStr = exchange.getIn().getBody(String.class);
                     JSONObject json = JSONObject.parseObject(jsonStr);
                     JSONObject json = JSONObject.parseObject(jsonStr);
                     exchange.setProperty("venderId", json.getString("venderId"));
                     exchange.setProperty("venderId", json.getString("venderId"));
                     exchange.getIn().setBody(jsonStr);
                     exchange.getIn().setBody(jsonStr);
+
                 })
                 })
                 .to("direct:getPropertiesByPj")
                 .to("direct:getPropertiesByPj")
                 .process(new GetVenderBySpecProcessor())
                 .process(new GetVenderBySpecProcessor())