From a27a4a85df394d84a48434b44d4f3a105b18a31f Mon Sep 17 00:00:00 2001
From: Ludovic Claude <ludovic.claude@laposte.net>
Date: Mon, 14 May 2018 23:14:03 +0200
Subject: [PATCH] Update woken-messages to 2.7.5, configurable cluster name
---
pom.xml | 2 +-
.../java/eu/hbp/mip/configuration/AkkaConfiguration.java | 7 ++++++-
2 files changed, 7 insertions(+), 2 deletions(-)
diff --git a/pom.xml b/pom.xml
index d6da18982..0912a01cc 100644
--- a/pom.xml
+++ b/pom.xml
@@ -47,7 +47,7 @@
<spring-data-jpa.version>1.10.11.RELEASE</spring-data-jpa.version>
<spring-boot-starter-actuator.version>1.4.7.RELEASE</spring-boot-starter-actuator.version>
<aspectjweaver.version>1.8.9</aspectjweaver.version>
- <woken-messages.version>2.7.4</woken-messages.version>
+ <woken-messages.version>2.7.5</woken-messages.version>
<javax-inject.version>1</javax-inject.version>
<akka.version>2.5.12</akka.version>
<spring-context.version>4.3.4.RELEASE</spring-context.version>
diff --git a/src/main/java/eu/hbp/mip/configuration/AkkaConfiguration.java b/src/main/java/eu/hbp/mip/configuration/AkkaConfiguration.java
index d2f285d45..4f4ae846f 100644
--- a/src/main/java/eu/hbp/mip/configuration/AkkaConfiguration.java
+++ b/src/main/java/eu/hbp/mip/configuration/AkkaConfiguration.java
@@ -52,7 +52,7 @@ class AkkaConfiguration {
public ExtendedActorSystem actorSystem() {
LOGGER.info("Step 1/3: Starting actor system...");
LOGGER.info("Create actor system at " + wokenClusterHost() + ":" + wokenClusterPort());
- ExtendedActorSystem system = (ExtendedActorSystem) ActorSystem.create("woken", config);
+ ExtendedActorSystem system = (ExtendedActorSystem) ActorSystem.create(wokenClusterName(), config);
SPRING_EXTENSION_PROVIDER.get(system).initialize(applicationContext);
return system;
}
@@ -95,6 +95,11 @@ class AkkaConfiguration {
return config.getString("clustering.ip");
}
+ @Bean
+ public String wokenClusterName() {
+ return config.getString("clustering.cluster.name");
+ }
+
@Bean
public Integer wokenClusterPort() {
return config.getInt("clustering.port");
--
GitLab