fix problem with akka + stop actors when received experiments results + add integration test draft

src/main/java/eu/hbp/mip/akka/ExperimentActor.java

@@ -31,23 +31,23 @@ public class ExperimentActor extends UntypedActor {
 
     @Override
     public void onReceive(Object message) {
-        log.info("\n\n***** ExperimentActor received response from woken\n");
+        log.info("ActorExperiment - onReceive method has been called");
         UUID uuid = UUID.fromString(this.getSelf().path().name());
+        log.info("\n\nExperimentActor received response from woken for UUID: \n"+uuid.toString());
         if (message instanceof QueryResult) {
             QueryResult queryResult = (QueryResult) message;
-            log.info("received query result for : " + uuid.toString());
             Experiment experiment = experimentRepository.findOne(uuid);
             if(experiment == null)
             {
                 log.error("Experiment with UUID="+uuid+" not found in DB");
-                // getContext().stop(getSelf());
+                getContext().stop(getSelf());
                 return;
             }
             experiment.setResult(queryResult.data().get());
             experiment.setFinished(new Date());
             experimentRepository.save(experiment);
             log.info("Experiment "+ uuid +" updated (finished)");
-            // getContext().stop(getSelf());
+            getContext().stop(getSelf());
         }
 
         else if (message instanceof QueryError) {
@@ -57,7 +57,7 @@ public class ExperimentActor extends UntypedActor {
             if(experiment == null)
             {
                 log.error("Experiment with UUID="+uuid+" not found in DB");
-                // getContext().stop(getSelf());
+                getContext().stop(getSelf());
                 return;
             }
             experiment.setHasServerError(true);
@@ -66,7 +66,7 @@ public class ExperimentActor extends UntypedActor {
             experiment.setFinished(new Date());
             experimentRepository.save(experiment);
             log.info("Experiment "+ uuid +" updated (finished)");
-            // getContext().stop(getSelf());
+            getContext().stop(getSelf());
         }
 
         else {

src/main/resources/application.conf

@@ -2,7 +2,7 @@ akka {
   actor {
     provider = "akka.remote.RemoteActorRefProvider"
   }
-  loglevel = DEBUG
+  loglevel = INFO
   log-config-on-start = on
   debug {
     autoreceive = on
@@ -12,19 +12,20 @@ akka {
     event-stream = on
   }
   remote {
+    maximum-payload-bytes = 10000000 bytes
     log-sent-messages = on
     log-received-messages = on
     enabled-transports = ["akka.remote.netty.tcp"]
     netty.tcp {
+      message-frame-size =  10000000b
+      send-buffer-size =  10000000b
+      receive-buffer-size =  10000000b
+      maximum-frame-size = 10000000b
       hostname = 127.0.0.1          # external (logical) hostname
       port = 8089                   # external (logical) port
 
       bind-hostname = 0.0.0.0       # internal (bind) hostname
       bind-port = 8089              # internal (bind) port
     }
-    message-frame-size =  10000000b
-    send-buffer-size =  10000000b
-    receive-buffer-size =  10000000b
-    maximum-frame-size = 10000000b
   }
 }
\ No newline at end of file

tests/integration/algorithmsFactory/test.sh

 #!/usr/bin/env bash
 
+# Create some test models
+echo ""
+echo "Creating some models..."
 curl http://backend:8080/services/models -X POST -H "Content-Type: application/json" -d @model1.json
-curl http://backend:8080/services/experiments -X POST -H "Content-Type: application/json" -d @expQuery1.json
+curl http://backend:8080/services/models -X POST -H "Content-Type: application/json" -d @model2.json
+
+# Run some experiments
+echo ""
+echo "Run some experiments..."
+response=$(curl -s http://backend:8080/services/experiments -X POST -H "Content-Type: application/json" -d @expQuery1.json)
+echo "exp1: $response"
+response=$(curl -s http://backend:8080/services/experiments -X POST -H "Content-Type: application/json" -d @expQuery2.json)
+echo "exp2: $response"
+response=$(curl -s http://backend:8080/services/experiments -X POST -H "Content-Type: application/json" -d @expQuery3.json)
+echo "exp3: $response"
\ No newline at end of file