wip

Author: eed3si9n

integrateion-test/src/sbt-test/bootstrap-demo/dns-kubernetes/src/main/resources/application.conf

@@ -7,15 +7,15 @@ akka {
   #   provider = "cluster"
   # }
 
-  # management {
-  #   cluster.bootstrap {
-  #     contact-point-discovery {
-  #       port-name = "akka-mgmt-http"
+  management {
+    cluster.bootstrap {
+      contact-point-discovery {
+        port-name = "akka-mgmt-http"
   #       protocol = "tcp"
   #       service-name = "bootstrap-demo-kubernetes-dns-internal"
   #       # Can be removed once https://github.com/akka/akka/issues/25825 is implemented
   #       service-namespace = ${NAMESPACE}".svc.cluster.local"
-  #     }
-  #   }
-  # }
+      }
+    }
+  }
 }

integrateion-test/src/sbt-test/bootstrap-demo/dns-kubernetes/src/main/scala/foo/ClusterApp.scala

@@ -12,7 +12,7 @@ import akka.http.scaladsl.Http
 import akka.http.scaladsl.model._
 import akka.http.scaladsl.server.Directives._
 import akka.management.AkkaManagement
-import akka.management.cluster.bootstrap.ClusterBootstrap
+import akka.management.cluster.bootstrap.{ ClusterBootstrap, ClusterBootstrapSettings }
 import akka.stream.ActorMaterializer
 
 object ClusterApp {
@@ -25,6 +25,10 @@ object ClusterApp {
     val cluster = Cluster(system)
 
     system.log.info("Starting Akka Management")
+
+    val settings = ClusterBootstrapSettings(system.settings.config, system.log)
+    sys.error(s"portName: ${settings.contactPointDiscovery.portName}")
+
     AkkaManagement(system).start()
     ClusterBootstrap(system).start()