Resolve "TMF628: Return unfinished Measurement Collection Jobs and expose them through the MQ"

Closes #66

src/main/java/org/etsi/osl/tmf/pm628/api/MeasurementCollectionJobApiRouteBuilder.java

@@ -41,6 +41,9 @@ public class MeasurementCollectionJobApiRouteBuilder extends RouteBuilder {
     @Value("${PM_MEASUREMENT_COLLECTION_JOB_UPDATE}")
     private String PM_UPDATE_MEASUREMENT_COLLECTION_JOB;
 
+    @Value("${PM_MEASUREMENT_COLLECTION_JOB_GET_INPRORGESS_OR_PENDING}")
+    private String PM_MEASUREMENT_COLLECTION_JOB_GET_INPRORGESS_OR_PENDING;
+
     @Autowired
     private ProducerTemplate template;
 
@@ -58,6 +61,7 @@ public class MeasurementCollectionJobApiRouteBuilder extends RouteBuilder {
             .bean(measurementCollectionJobService, "findAllMeasurementCollectionJobs")
             .convertBodyTo( String.class );
 
+
         from(PM_MEASUREMENT_COLLECTION_GET_JOB_BY_ID)
             .log(LoggingLevel.INFO, log, PM_MEASUREMENT_COLLECTION_GET_JOB_BY_ID + " message received!")
             .to("log:DEBUG?showBody=true&showHeaders=true")
@@ -80,6 +84,12 @@ public class MeasurementCollectionJobApiRouteBuilder extends RouteBuilder {
                 .bean(measurementCollectionJobService, "updateMeasurementCollectionJob(${header.mcjid}, ${body})")
                 .marshal().json( JsonLibrary.Jackson)
                 .convertBodyTo( String.class );
+
+        from(PM_MEASUREMENT_COLLECTION_JOB_GET_INPRORGESS_OR_PENDING)
+                .log(LoggingLevel.INFO, log, PM_MEASUREMENT_COLLECTION_JOB_GET_INPRORGESS_OR_PENDING + " message received!")
+                .to("log:DEBUG?showBody=true&showHeaders=true")
+                .bean(measurementCollectionJobService, "findPendingOrInProgressMeasurementCollectionJobs")
+                .convertBodyTo( String.class );
     }
 
     static String toJsonString(Object object) throws IOException {