diff --git a/src/main/java/eu/dnetlib/validatorapi/routes/FairOaiPmhRoute2.java b/src/main/java/eu/dnetlib/validatorapi/routes/FairOaiPmhRoute2.java index 132900e..bf0128a 100644 --- a/src/main/java/eu/dnetlib/validatorapi/routes/FairOaiPmhRoute2.java +++ b/src/main/java/eu/dnetlib/validatorapi/routes/FairOaiPmhRoute2.java @@ -126,7 +126,6 @@ public class FairOaiPmhRoute2 extends RouteBuilder { .multicast().parallelProcessing() .to("direct:guidelinesProcessor") .to("direct:fairProcessor") - .to("controlbus:route?routeId=1&action=stop&async=true") .endChoice() .otherwise() .process(new ErrorProcessor(validationJob)) @@ -157,7 +156,8 @@ public class FairOaiPmhRoute2 extends RouteBuilder { /*.process(new DataBaseProcessor()) .to("jpa:" + ValidationJob.class.getName() + "?useExecuteUpdate=true")//;.to("direct:saveToDatabase")*/ .to("controlbus:route?routeId="+routeid+"&action=stop&async=true") - .endChoice() + .to("controlbus:route?routeId=1&action=stop&async=true") + .endChoice() .end(); from("direct:fairProcessor") @@ -183,7 +183,8 @@ public class FairOaiPmhRoute2 extends RouteBuilder { /*.process(new DataBaseProcessor()) .to("jpa:" + ValidationJob.class.getName() + "?useExecuteUpdate=true")//;.to("direct:saveToDatabase")*/ .to("controlbus:route?routeId="+routeid2+"&action=stop&async=true") - .endChoice() + .to("controlbus:route?routeId=1&action=stop&async=true") + .endChoice() .end(); /*