diff --git a/engine/src/main/resources/application.conf b/engine/src/main/resources/application.conf index bab83ff..097ed2a 100644 --- a/engine/src/main/resources/application.conf +++ b/engine/src/main/resources/application.conf @@ -48,13 +48,13 @@ app { //Default Thumbnail Settings thumbnail { //Directory where to store thumbnails - directory = ".cache/thumbnails/" + directory = "./cache/thumbnails/" //Size of the thumbnail to generate and store size = 128 } //Default Database Settings database { - connectionURL = "jdbc:h2:.cache/imageTools" + connectionURL = "jdbc:h2:./cache/imageTools" inMemory = false } } \ No newline at end of file diff --git a/engine/src/main/scala/com/sothr/imagetools/engine/ConcurrentEngine.scala b/engine/src/main/scala/com/sothr/imagetools/engine/ConcurrentEngine.scala index 097c066..3802a98 100644 --- a/engine/src/main/scala/com/sothr/imagetools/engine/ConcurrentEngine.scala +++ b/engine/src/main/scala/com/sothr/imagetools/engine/ConcurrentEngine.scala @@ -3,13 +3,14 @@ package com.sothr.imagetools.engine import java.io.File import java.util.concurrent.TimeUnit -import akka.actor._ +import akka.actor.{Actor, ActorLogging, ActorRef, PoisonPill, Props} import akka.pattern.ask -import akka.routing.{Broadcast, RoundRobinRouter, SmallestMailboxRouter} +import akka.routing.{Broadcast, RoundRobinPool, SmallestMailboxPool} import akka.util.Timeout import com.sothr.imagetools.engine.hash.HashService import com.sothr.imagetools.engine.image.{Image, ImageService, SimilarImages} -import com.sothr.imagetools.engine.util._ +import com.sothr.imagetools.engine.util +import com.sothr.imagetools.engine.util.{PropertiesService, PropertyEnum} import scala.collection.mutable import scala.concurrent.Await @@ -134,7 +135,7 @@ class ConcurrentEngineProcessingController extends Actor with ActorLogging { if (processors > max) threads = max else if (processors > 1) threads = processors - 1 else threads = 1 threads } - var router = context.actorOf(Props[ConcurrentEngineProcessingActor].withRouter(SmallestMailboxRouter(nrOfInstances = numOfRouters))) + var router = context.actorOf(Props[ConcurrentEngineProcessingActor].withRouter(SmallestMailboxPool(nrOfInstances = numOfRouters))) var images: mutable.MutableList[Image] = new mutable.MutableList[Image]() var toProcess = 0 @@ -288,7 +289,7 @@ class ConcurrentEngineSimilarityController extends Actor with ActorLogging { if (processors > max) threads = max else if (processors > 1) threads = processors - 1 else threads = 1 threads } - val router = context.actorOf(Props[ConcurrentEngineSimilarityActor].withRouter(RoundRobinRouter(nrOfInstances = numOfRouters))) + val router = context.actorOf(Props[ConcurrentEngineSimilarityActor].withRouter(RoundRobinPool(nrOfInstances = numOfRouters))) val allSimilarImages = new mutable.MutableList[SimilarImages] var toProcess = 0 diff --git a/parent/pom.xml b/parent/pom.xml index 52949c5..91f1479 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -62,27 +62,27 @@ 0.1.2 UTF-8 1.8 - 2.11 - 2.11.2 - 4.11 - 2.2.1 - 1.1.2 - 1.7.7 - 1.0.2 - 2.3.5 + 2.12 + 2.12.4 + 4.12 + 3.0.4 + 1.2.3 + 1.7.25 + 1.3.2 + 2.5.8 1.1 - 2.8.0 - 1.2 - 1.9 + 2.10.4 + 1.4 + 1.11 2.4.0 - 1.2.0 + 1.3.2 [0.4, 0.5) - 1.3.175 - 4.3.0.Final - 2.6.6 - 2.2-cj-1.0 - 1.4 - 3.0 + 1.4.196 + 4.3.11.Final + 2.6.11 + 2.2-cj-1.1 + 2.0 + 3.3.2 @@ -171,7 +171,7 @@ com.typesafe.akka - akka-actor_2.11 + akka-actor_${scala.binary.version} ${lib.akka.version}