diff --git a/ch.psi.fda/src/main/java/ch/psi/fda/rest/services/ExecutionService.java b/ch.psi.fda/src/main/java/ch/psi/fda/rest/services/ExecutionService.java index 3bf52d9..8fd74d6 100644 --- a/ch.psi.fda/src/main/java/ch/psi/fda/rest/services/ExecutionService.java +++ b/ch.psi.fda/src/main/java/ch/psi/fda/rest/services/ExecutionService.java @@ -20,6 +20,7 @@ package ch.psi.fda.rest.services; import java.util.concurrent.ExecutionException; +import java.util.logging.Logger; import javax.inject.Inject; import javax.ws.rs.Consumes; @@ -35,7 +36,9 @@ import ch.psi.fda.rest.ExecutionEngine; @Path("fda") public class ExecutionService { - + + private static final Logger logger = Logger.getLogger(ExecutionService.class.getName()); + @Inject private ExecutionEngine aengine; @@ -43,29 +46,34 @@ public class ExecutionService { @Path("{trackingId}") @Consumes({MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML}) public void execute(@PathParam("trackingId") String trackingId, EDescriptor edescriptor) throws InterruptedException{ + logger.info("Submitting job with tracking id "+trackingId); aengine.submit(trackingId, edescriptor); } @DELETE @Path("{trackingId}") public void stop(@PathParam("trackingId") String trackingId){ + logger.info("Stopping job with tracking id "+trackingId); aengine.terminate(trackingId); } @DELETE public void terminateAll(){ + logger.info("Terminate all jobs"); aengine.terminateAll(); } @GET @Path("{trackingId}/running") public boolean isActive(@PathParam("trackingId") String trackingId){ + logger.info("Check whether job with tracking id "+trackingId+" is running"); return aengine.isActive(trackingId); } @GET @Path("{trackingId}/done") public void wait(@PathParam("trackingId") String trackingId) throws InterruptedException, ExecutionException{ + logger.info("Wait for job with tracking id "+trackingId+" to be finished"); aengine.wait(trackingId); }