From ee6c90ac937f5e8a27fa17fdfb78cf333ad983cd Mon Sep 17 00:00:00 2001 From: awazalwar Date: Fri, 11 Mar 2016 16:37:16 -0500 Subject: [PATCH] #1109 Rolling back request parameter support for setting queueSize --- .../HystrixMetricsStreamServlet.java | 28 ++++++------------- 1 file changed, 9 insertions(+), 19 deletions(-) diff --git a/hystrix-contrib/hystrix-metrics-event-stream/src/main/java/com/netflix/hystrix/contrib/metrics/eventstream/HystrixMetricsStreamServlet.java b/hystrix-contrib/hystrix-metrics-event-stream/src/main/java/com/netflix/hystrix/contrib/metrics/eventstream/HystrixMetricsStreamServlet.java index caaa77a79..6dd8c07a8 100644 --- a/hystrix-contrib/hystrix-metrics-event-stream/src/main/java/com/netflix/hystrix/contrib/metrics/eventstream/HystrixMetricsStreamServlet.java +++ b/hystrix-contrib/hystrix-metrics-event-stream/src/main/java/com/netflix/hystrix/contrib/metrics/eventstream/HystrixMetricsStreamServlet.java @@ -15,22 +15,20 @@ */ package com.netflix.hystrix.contrib.metrics.eventstream; -import java.io.IOException; -import java.util.ArrayList; -import java.util.List; -import java.util.concurrent.LinkedBlockingQueue; -import java.util.concurrent.atomic.AtomicInteger; +import com.netflix.config.DynamicIntProperty; +import com.netflix.config.DynamicPropertyFactory; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import javax.servlet.ServletException; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; - -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import com.netflix.config.DynamicIntProperty; -import com.netflix.config.DynamicPropertyFactory; +import java.io.IOException; +import java.util.ArrayList; +import java.util.List; +import java.util.concurrent.LinkedBlockingQueue; +import java.util.concurrent.atomic.AtomicInteger; /** * Streams Hystrix metrics in text/event-stream format. @@ -137,14 +135,6 @@ private void handleRequest(HttpServletRequest request, HttpServletResponse respo response.setHeader("Pragma", "no-cache"); int queueSize = defaultMetricListenerQueueSize.get(); - try { - String q = request.getParameter("queueSize"); - if (q != null) { - queueSize = Integer.parseInt(q); - } - } catch (Exception e) { - // ignore if it's not a number - } MetricJsonListener jsonListener = new MetricJsonListener(queueSize); poller = new HystrixMetricsPoller(jsonListener, delay);