diff --git a/src/main/java/eu/dnetlib/validatorapi/routes/SimpleOaiPmhRoute.java b/src/main/java/eu/dnetlib/validatorapi/routes/SimpleOaiPmhRoute.java
index 999503d..e21de77 100644
--- a/src/main/java/eu/dnetlib/validatorapi/routes/SimpleOaiPmhRoute.java
+++ b/src/main/java/eu/dnetlib/validatorapi/routes/SimpleOaiPmhRoute.java
@@ -61,12 +61,12 @@ public class SimpleOaiPmhRoute extends RouteBuilder {
             .routeId(routeid)
                 .choice()
                     .when(xpath("//*[local-name()='record']"))
-                    .multicast().parallelProcessing()
                     .to("direct:oaipmhProcessor")
                 .endChoice()
                 .otherwise()
                     .process(new ErrorProcessor(validationJob))
                     .to("jpa:" + ValidationJob.class.getName() + "?useExecuteUpdate=true")
+                    .to("controlbus:route?routeId="+routeid+"&action=stop")
                 .end();
 
         from("direct:oaiPmhProcessor")