add a monitoring uri config (#96)

* add a monitoring uri config

* use host and port instead of URI

Author: BrandonArp

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

@@ -77,6 +77,8 @@
 
 import java.io.File;
 import java.io.IOException;
+import java.net.URI;
+import java.net.URISyntaxException;
 import java.util.Collections;
 import java.util.Locale;
 import java.util.Map;
@@ -141,8 +143,12 @@ private Config provideAkkaConfig() {
     @Provides
     @Singleton
     @SuppressFBWarnings("UPM_UNCALLED_PRIVATE_METHOD") // Invoked reflectively by Guice
-    private MetricsFactory provideMetricsFactory() {
+    private MetricsFactory provideMetricsFactory() throws URISyntaxException {
         final Sink sink = new ApacheHttpSink.Builder()
+                .setUri(new URI(String.format(
+                        "http://%s:%d/metrics/v2/application",
+                        _configuration.getMonitoringHost(),
+                        _configuration.getMonitoringPort())))
                 .build();
 
         return new TsdMetricsFactory.Builder()

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

@@ -53,6 +53,14 @@ public String getMonitoringService() {
         return _monitoringService;
     }
 
+    public String getMonitoringHost() {
+        return _monitoringHost;
+    }
+
+    public int getMonitoringPort() {
+        return _monitoringPort;
+    }
+
     public int getHttpPort() {
         return _httpPort;
     }
@@ -164,6 +172,8 @@ public String toString() {
     private ClusterAggregatorConfiguration(final Builder builder) {
         _monitoringCluster = builder._monitoringCluster;
         _monitoringService = builder._monitoringService;
+        _monitoringHost = builder._monitoringHost;
+        _monitoringPort = builder._monitoringPort;
         _httpHost = builder._httpHost;
         _httpPort = builder._httpPort;
         _httpHealthCheckPath = builder._httpHealthCheckPath;
@@ -188,6 +198,8 @@ private ClusterAggregatorConfiguration(final Builder builder) {
 
     private final String _monitoringCluster;
     private final String _monitoringService;
+    private final String _monitoringHost;
+    private final int _monitoringPort;
     private final File _logDirectory;
     private final String _httpHost;
     private final int _httpPort;
@@ -245,6 +257,30 @@ public Builder setMonitoringService(final String value) {
             return this;
         }
 
+        /**
+         * The monitoring endpoint host (Where to post data). Optional. Cannot be null or empty. Default
+         * is 'localhost'.
+         *
+         * @param value The monitoring endpoint uri.
+         * @return This instance of <code>Builder</code>.
+         */
+        public Builder setMonitoringHost(final String value) {
+            _monitoringHost = value;
+            return this;
+        }
+
+        /**
+         * The monitoring endpoint port. Optional. Cannot be null, must be between 1 and
+         * 65535 (inclusive). Defaults to 7090.
+         *
+         * @param value The port to listen on.
+         * @return This instance of <code>Builder</code>.
+         */
+        public Builder setMonitoringPort(final Integer value) {
+            _monitoringPort = value;
+            return this;
+        }
+
         /**
          * The http host address to bind to. Cannot be null or empty.
          *
@@ -489,6 +525,12 @@ public Builder setCalculateClusterAggregations(final Boolean value) {
         private String _monitoringService = "cluster_aggregator";
         @NotNull
         @NotEmpty
+        private String _monitoringHost = "localhost";
+        @NotNull
+        @Range(min = 1, max = 65535)
+        private Integer _monitoringPort = 7090;
+        @NotNull
+        @NotEmpty
         private String _httpHost = "0.0.0.0";
         @NotNull
         @Range(min = 1, max = 65535)