Improved logging

This commit is contained in:
2014-05-06 13:50:50 +02:00
parent 16d18288b6
commit 3ce7282214

View File

@@ -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);
}