multicast is not supposed to be in the simple route.

This commit is contained in:
Katerina 2023-09-20 14:58:35 +03:00
parent ee55fd2b99
commit 2454c900aa
1 changed files with 1 additions and 1 deletions

View File

@ -61,12 +61,12 @@ public class SimpleOaiPmhRoute extends RouteBuilder {
.routeId(routeid) .routeId(routeid)
.choice() .choice()
.when(xpath("//*[local-name()='record']")) .when(xpath("//*[local-name()='record']"))
.multicast().parallelProcessing()
.to("direct:oaipmhProcessor") .to("direct:oaipmhProcessor")
.endChoice() .endChoice()
.otherwise() .otherwise()
.process(new ErrorProcessor(validationJob)) .process(new ErrorProcessor(validationJob))
.to("jpa:" + ValidationJob.class.getName() + "?useExecuteUpdate=true") .to("jpa:" + ValidationJob.class.getName() + "?useExecuteUpdate=true")
.to("controlbus:route?routeId="+routeid+"&action=stop")
.end(); .end();
from("direct:oaiPmhProcessor") from("direct:oaiPmhProcessor")