From 1b5f77745f948beca5db9456f1933d2b4fe637f3 Mon Sep 17 00:00:00 2001
From: Mirco Nasuti <mirco.nasuti@chuv.ch>
Date: Wed, 30 Nov 2016 15:27:28 +0100
Subject: [PATCH] save results when received experiment results
---
src/main/java/eu/hbp/mip/akka/ExperimentActor.java | 12 ++++++++++++
1 file changed, 12 insertions(+)
diff --git a/src/main/java/eu/hbp/mip/akka/ExperimentActor.java b/src/main/java/eu/hbp/mip/akka/ExperimentActor.java
index a78356246..8e29f1762 100644
--- a/src/main/java/eu/hbp/mip/akka/ExperimentActor.java
+++ b/src/main/java/eu/hbp/mip/akka/ExperimentActor.java
@@ -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);
--
GitLab