낙타 경로 루프가 작동하지 않습니다.

Question

낙타와 동면을 사용하여 mySQL 데이터베이스에 json 데이터를 삽입하려고합니다. 모든 것이 효과적입니다.

for (Module module : modules) { 
      from("timer://foo?delay=10000") 
        .loop(7)//not working 
        .to(module.getUrl() + "/api/json") 
        .convertBodyTo(String.class) 
        .process(new Processor() { 
         @Override 
         public void process(Exchange exchange) throws Exception { 
          int index = (Integer)exchange.getProperty("CamelLoopIndex"); // not working 
          ObjectMapper mapper = new ObjectMapper(); 
          JsonNode root = mapper.readTree(exchange.getIn().getBody().toString()); 
          String[] lijst = {"lastBuild", "lastCompletedBuild", "lastFailedBuild", "lastStableBuild", "lastSuccessfulBuild", "lastUnstableBuild", "lastUnsuccessfulBuild"}; 

          JSONObject obj = new JSONObject(); 

          JsonNode node = root.get(lijst[index]); 
          JsonNode build = node.get("number"); 
          obj.put("description", lijst[index]); 
          obj.put("buildNumber", build); 

          exchange.getIn().setBody(obj.toString()); 

         } 
        }) 
        .unmarshal(moduleDetail) 
        .to("hibernate:be.kdg.teamf.model.ModuleDetail") 
        .end(); 
     } 

내가 디버깅

, 내 CamelLoopIndex은 0이되므로은 (는) 루프를 통과 할 때마다 증가하지 않습니다 남아있다.

모든 도움을 환영합니다!

Answer 1

유일한 경우 첫 번째 명령은 루프 범위에서 처리됩니다 (.to(module.getUrl() + "/api/json")). Spring DSL을 사용하여 루프에 더 많은 명령어를 추가 할 수 있지만 Java DSL을 명시 적으로 사용하여 루프 범위를 선언하는 방법을 알지 못합니다. 전문가들이 Java DSL의 루프 범위에 대해 더 자세히 설명해주기를 바랍니다.

해결 방법으로 모든 반복 지침을 별도의 direct: 경로로 이동하는 것이 좋습니다.

Answer 2

문제점을 재현 할 수 없습니다. 이 작품 :

는

from("restlet:http://localhost:9010}/loop?restletMethod=get") 
    .loop(7) 
    .process(new Processor() { 
    @Override 
    public void process(Exchange exchange) throws Exception { 
     int index = (int) exchange.getProperty("CamelLoopIndex"); 
     exchange.getIn().setBody("index=" + index); 
    } 
    }) 
    .convertBodyTo(String.class) 
    .end(); 

출력 :

index=6