MaDgIK
/
uoa-validator-api
13
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fixed the premature ending of the double processing.

This commit is contained in:
Katerina 2023-12-14 13:00:12 +02:00
parent b72c29b8c8
commit d42d8fc09b
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/eu/dnetlib/validatorapi/routes/FairOaiPmhRoute2.java
View File

@ -126,7 +126,6 @@ public class FairOaiPmhRoute2 extends RouteBuilder {
.multicast().parallelProcessing() .multicast().parallelProcessing()
.to("direct:guidelinesProcessor") .to("direct:guidelinesProcessor")
.to("direct:fairProcessor") .to("direct:fairProcessor")
.to("controlbus:route?routeId=1&action=stop&async=true")
.endChoice() .endChoice()
.otherwise() .otherwise()
.process(new ErrorProcessor(validationJob)) .process(new ErrorProcessor(validationJob))
@ -157,7 +156,8 @@ public class FairOaiPmhRoute2 extends RouteBuilder {
/*.process(new DataBaseProcessor()) /*.process(new DataBaseProcessor())
.to("jpa:" + ValidationJob.class.getName() + "?useExecuteUpdate=true")//;.to("direct:saveToDatabase")*/ .to("jpa:" + ValidationJob.class.getName() + "?useExecuteUpdate=true")//;.to("direct:saveToDatabase")*/
.to("controlbus:route?routeId="+routeid+"&action=stop&async=true") .to("controlbus:route?routeId="+routeid+"&action=stop&async=true")
.endChoice() .to("controlbus:route?routeId=1&action=stop&async=true")
.endChoice()
.end(); .end();
from("direct:fairProcessor") from("direct:fairProcessor")
@ -183,7 +183,8 @@ public class FairOaiPmhRoute2 extends RouteBuilder {
/*.process(new DataBaseProcessor()) /*.process(new DataBaseProcessor())
.to("jpa:" + ValidationJob.class.getName() + "?useExecuteUpdate=true")//;.to("direct:saveToDatabase")*/ .to("jpa:" + ValidationJob.class.getName() + "?useExecuteUpdate=true")//;.to("direct:saveToDatabase")*/
.to("controlbus:route?routeId="+routeid2+"&action=stop&async=true") .to("controlbus:route?routeId="+routeid2+"&action=stop&async=true")
.endChoice() .to("controlbus:route?routeId=1&action=stop&async=true")
.endChoice()
.end(); .end();
/* /*