0

camel と hibernate を使用して、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 のままなので、ループを通過するたびにインクリメントされません。

すべてのヘルプは大歓迎です!

4

2 に答える 2