Refactor to separate method.

1 files changed, 10 insertions, 7 deletions

diff --git a/jdisc_http_service/src/main/java/com/yahoo/jdisc/http/server/jetty/HttpRequestDispatch.java b/jdisc_http_service/src/main/java/com/yahoo/jdisc/http/server/jetty/HttpRequestDispatch.java
index 6dd4e30c768..9e15f45b046 100644
--- a/jdisc_http_service/src/main/java/com/yahoo/jdisc/http/server/jetty/HttpRequestDispatch.java
+++ b/jdisc_http_service/src/main/java/com/yahoo/jdisc/http/server/jetty/HttpRequestDispatch.java
@@ -60,13 +60,7 @@ class HttpRequestDispatch {
         this.metricReporter = new MetricReporter(jDiscContext.metric, metricContext,
                 ((org.eclipse.jetty.server.Request) servletRequest).getTimeStamp());
         this.servletRequest = servletRequest;
-        if (jDiscContext.serverConfig.maxKeepAliveRequests() > 0) {
-            HttpConnection connection = JDiscHttpServlet.getConnection(servletRequest);
-            if (connection.getMessagesIn() >= jDiscContext.serverConfig.maxKeepAliveRequests()) {
-                connection.getGenerator().setPersistent(false);
-            }
-        }
-
+        honourMaxKeepAliveRequests();
         this.servletResponseController = new ServletResponseController(
                 servletResponse,
                 jDiscContext.janitor,
@@ -102,6 +96,15 @@ class HttpRequestDispatch {
         }
     }
 
+    private void honourMaxKeepAliveRequests() {
+        if (jDiscContext.serverConfig.maxKeepAliveRequests() > 0) {
+            HttpConnection connection = JDiscHttpServlet.getConnection(servletRequest);
+            if (connection.getMessagesIn() >= jDiscContext.serverConfig.maxKeepAliveRequests()) {
+                connection.getGenerator().setPersistent(false);
+            }
+        }
+    }
+
     private BiConsumer<Void, Throwable> completeRequestCallback;
     {
         AtomicBoolean completeRequestCalled = new AtomicBoolean(false);