Add cluster management

Author: jmarin

api/src/main/resources/application.conf

@@ -26,6 +26,13 @@ akka {
     //DON'T USE IN PRODUCTION!!!!!
     auto-down-unreachable-after = 10s
 
+    http {
+      management {
+        hostname = "127.0.0.1"
+        port = 9999
+      }
+    }
+
   }
 
   extensions = ["de.heikoseeberger.constructr.ConstructrExtension"]

api/src/main/scala/hmda/api/HmdaPlatform.scala

@@ -3,6 +3,8 @@ package hmda.api
 import java.io.File
 
 import akka.actor._
+import akka.cluster.Cluster
+import akka.cluster.http.management.ClusterHttpManagement
 import akka.pattern.ask
 import akka.util.Timeout
 
@@ -32,6 +34,8 @@ object HmdaPlatform {
   def main(args: Array[String]): Unit = {
 
     val system = ActorSystem(configuration.getString("clustering.name"), configuration)
+    val cluster = Cluster(system)
+    ClusterHttpManagement(cluster).start()
     val supervisor = createSupervisor(system)
     val querySupervisor = createQuerySupervisor(system)
     implicit val ec = system.dispatcher

build.sbt

@@ -6,7 +6,7 @@ import org.scalajs.sbtplugin.ScalaJSPlugin.autoImport._
 
 val commonDeps = Seq(logback, scalaTest, scalaCheck)
 
-val akkaDeps = commonDeps ++ Seq(akka, akkaCluster, akkaSlf4J, akkaStream, akkaTestkit, constructr, constructrZookeeper)
+val akkaDeps = commonDeps ++ Seq(akka, akkaCluster, akkaSlf4J, akkaStream, akkaTestkit, constructr, constructrZookeeper, akkaClusterManagement)
 
 val akkaPersistenceDeps = akkaDeps ++ Seq(akkaPersistence, akkaStream, leveldb, leveldbjni, akkaPersistenceQuery, inMemoryPersistence, cassandraPersistence)
 

project/Dependencies.scala

@@ -15,6 +15,7 @@ object Dependencies {
   val akkaSlf4J = "com.typesafe.akka" %% "akka-slf4j" % Version.akka
   val akka = "com.typesafe.akka" %% "akka-actor" % Version.akka
   val akkaCluster = "com.typesafe.akka" %% "akka-cluster" % Version.akka
+  val akkaClusterManagement = "com.lightbend.akka" %% "akka-management-cluster-http" % Version.akkaClusterManagement
   val akkaTestkit = "com.typesafe.akka" %% "akka-testkit" % Version.akka % "test"
   val akkaStream = "com.typesafe.akka" %% "akka-stream" % Version.akka
   val akkaPersistence = "com.typesafe.akka" %% "akka-persistence" % Version.akka

project/Version.scala

@@ -5,6 +5,7 @@ object Version {
   val scalaCheck = "1.13.4"
   val scalaz     = "7.2.9"
   val akka       = "2.4.19"
+  val akkaClusterManagement = "0.3"
   val akkaHttp   = "10.0.8"
   val leveldb    = "0.7"
   val leveldbjni = "1.8"