diff --git a/src/main/java/eu/hbp/mip/akka/WokenClientController.java b/src/main/java/eu/hbp/mip/akka/WokenClientController.java index 27492898dcd945ca595505d57fa33b46b7ff562a..7557e637df5f501fc7d67b9a3383c2c64df9acbb 100644 --- a/src/main/java/eu/hbp/mip/akka/WokenClientController.java +++ b/src/main/java/eu/hbp/mip/akka/WokenClientController.java @@ -46,6 +46,7 @@ public abstract class WokenClientController { @PostConstruct public void initClusterClient() { + LOGGER.info("Start Woken client " + wokenReceptionistPath); wokenClient = actorSystem.actorOf(ClusterClient.props( ClusterClientSettings.create(actorSystem).withInitialContacts(initialContacts())), "client-" + getClass().getSimpleName()); diff --git a/src/main/java/eu/hbp/mip/configuration/AkkaConfiguration.java b/src/main/java/eu/hbp/mip/configuration/AkkaConfiguration.java index a99b5bfc1c90ee531e98d36fdda59d97a9550453..9cda0c97ec2464fb658da9fcb4b3aa07e49321ca 100644 --- a/src/main/java/eu/hbp/mip/configuration/AkkaConfiguration.java +++ b/src/main/java/eu/hbp/mip/configuration/AkkaConfiguration.java @@ -1,6 +1,8 @@ package eu.hbp.mip.configuration; import akka.actor.ActorSystem; +import com.typesafe.config.Config; +import com.typesafe.config.ConfigFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.context.ApplicationContext; @@ -32,7 +34,8 @@ class AkkaConfiguration { @Bean public ActorSystem actorSystem() { - ActorSystem system = ActorSystem.create("PortalBackend"); + Config config = ConfigFactory.load("application.conf"); + ActorSystem system = ActorSystem.create("PortalBackend", config); SPRING_EXTENSION_PROVIDER.get(system).initialize(applicationContext); return system; }