start the cluster joiner

Author: BrandonArp

src/main/java/com/arpnetworking/clusteraggregator/GuiceModule.java

@@ -245,6 +245,14 @@ private ActorRef provideTcpServer(final Injector injector, final ActorSystem sys
         return system.actorOf(GuiceActorCreator.props(injector, AggClientServer.class), "tcp-server");
     }
 
+    @Provides
+    @Singleton
+    @Named("cluster-joiner")
+    @SuppressFBWarnings("UPM_UNCALLED_PRIVATE_METHOD") // Invoked reflectively by Guice
+    private ActorRef provideClusterJoiner(final ActorSystem system, final ClusterAggregatorConfiguration config) {
+        return system.actorOf(config.getClusterJoinActor(), "cluster-joiner");
+    }
+
     @Provides
     @Singleton
     @Named("aggregator-lifecycle")

src/main/java/com/arpnetworking/clusteraggregator/Main.java

@@ -203,6 +203,11 @@ private void launchActors(final Injector injector) {
                 .log();
         injector.getInstance(Key.get(ActorRef.class, Names.named("jvm-metrics-collector")));
 
+        LOGGER.info()
+                .setMessage("Launching cluster joiner")
+                .log();
+        injector.getInstance(Key.get(ActorRef.class, Names.named("cluster-joiner")));
+
         LOGGER.info()
                 .setMessage("Launching http server")
                 .log();

src/main/java/com/arpnetworking/clusteraggregator/configuration/ClusterAggregatorConfiguration.java

@@ -116,6 +116,10 @@ public String getClusterHostSuffix() {
         return _clusterHostSuffix;
     }
 
+    public Props getClusterJoinActor() {
+        return _clusterJoinActor;
+    }
+
     /**
      * {@inheritDoc}
      */