Merge branch 'master' of https://github.com/cfpb/hmda-platform

Author: Kibrael

Documents/cluster.md

@@ -0,0 +1,6 @@
+# HMDA Akka Cluster Configuration
+
+## Cluster Management
+
+The project uses the [Akka Cluster HTTP Management](http://developer.lightbend.com/docs/akka-management/current/cluster-http-management.html) module to report on cluster member status as well as to perform cluster
+management tasks. Please refer to the documentation of this module for cluster management tasks (i.e. downing a node from the cluster)

README.md

@@ -72,7 +72,9 @@ In addition, you'll need Scala's interactive build tool [sbt](http://www.scala-s
 
 ## Building and Running
 
-The HMDA Platform uses sbt's multi-project builds, each project representing a specific task.
+The HMDA Platform uses sbt's multi-project builds, each project representing a specific task. The platform is an Akka Cluster
+application that can be deployed on a single node or as a distributed application. For more information on how Akka Cluster 
+is used, see the documentation [here](Documents/cluster.md)
 
 ### Interactive
 

api/src/main/resources/application.conf

@@ -23,8 +23,12 @@ akka {
 
     retry-unsuccessful-join-after = 20s
 
-    //DON'T USE IN PRODUCTION!!!!!
-    auto-down-unreachable-after = 10s
+    http {
+      management {
+        hostname = "127.0.0.1"
+        port = 9999
+      }
+    }
 
   }
 

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.dispatchers.lookup("api-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"

publication/src/main/resources/application.conf

@@ -28,9 +28,6 @@ akka {
 
     retry-unsuccessful-join-after = 20s
 
-    //DON'T USE IN PRODUCTION!!!!!
-    auto-down-unreachable-after = 10s
-
   }
 
 

query/src/main/resources/application.conf

@@ -27,9 +27,6 @@ akka {
 
     retry-unsuccessful-join-after = 20s
 
-    //DON'T USE IN PRODUCTION!!!!!
-    auto-down-unreachable-after = 10s
-
   }
 }