Merge pull request #12 from Netflix/pass_through_query_params

Pass through query params
Netflix · Aug 4, 2020 · 764e193 · 764e193
2 parents 4abb26b + 209ba5c
commit 764e193
Showing 1 changed file with 1 addition and 13 deletions.
diff --git a/src/main/java/io/mantisrx/api/push/ConnectionBroker.java b/src/main/java/io/mantisrx/api/push/ConnectionBroker.java
@@ -285,19 +285,7 @@ private Observable<String> getWorkerMetrics(PushConnectionDetails details) {
 
         final String jobId = details.target;
 
-        SinkParameters metricNamesFilter = new SinkParameters.Builder().build();
-        /*
-        try {
-            SinkParameters.Builder sinkParamsBuilder = new SinkParameters.Builder();
-            for (String metric : metricGroups) {
-                sinkParamsBuilder = sinkParamsBuilder.withParameter(METRIC_NAME_STR, metric);
-            }
-
-            metricNamesFilter = sinkParamsBuilder.build();
-        } catch (UnsupportedEncodingException e) {
-            log.error("error encoding sink parameters", e);
-        }
-         */
+        SinkParameters metricNamesFilter = details.getSinkparameters();
 
         final MetricsClient<MantisServerSentEvent> metricsClient = workerMetricsClient.getMetricsClientByJobId(jobId,
                 new SseWorkerConnectionFunction(true, new Action1<Throwable>() {