Skip to content
Snippets Groups Projects
Commit 1b5f7774 authored by Mirco Nasuti's avatar Mirco Nasuti
Browse files

save results when received experiment results

parent 99297052
No related branches found
No related tags found
No related merge requests found
......@@ -6,7 +6,11 @@ import akka.event.Logging;
import akka.event.LoggingAdapter;
import akka.japi.Creator;
import eu.hbp.mip.messages.external.QueryResult;
import eu.hbp.mip.model.Experiment;
import eu.hbp.mip.repositories.ExperimentRepository;
import org.springframework.beans.factory.annotation.Autowired;
import java.util.Date;
import java.util.UUID;
/**
......@@ -14,6 +18,9 @@ import java.util.UUID;
*/
public class ExperimentActor extends UntypedActor {
@Autowired
private ExperimentRepository experimentRepository;
public static Props props(final UUID expUUID) {
return Props.create(new Creator<ExperimentActor>() {
private static final long serialVersionUID = 1L;
......@@ -38,6 +45,11 @@ public class ExperimentActor extends UntypedActor {
if (message instanceof QueryResult) {
QueryResult queryResult = (QueryResult) message;
log.info("received query result for : " + expUUID.toString());
Experiment experiment = experimentRepository.findOne(expUUID);
experiment.setResult(queryResult.data().get());
experiment.setFinished(new Date());
experimentRepository.save(experiment);
log.info("Experiment "+ expUUID +" updated (finished)");
}
else {
unhandled(message);
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment