Skip to content
Snippets Groups Projects
Commit a27a4a85 authored by Ludovic Claude's avatar Ludovic Claude
Browse files

Update woken-messages to 2.7.5, configurable cluster name

parent 59ab42ca
No related branches found
No related tags found
No related merge requests found
......@@ -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>
......
......@@ -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");
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment