camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject [3/3] git commit: CAMEL-6629: Configure jetty connector request/response buffer sizes is easier.
Date Thu, 15 Aug 2013 13:30:34 GMT
CAMEL-6629: Configure jetty connector request/response buffer sizes is easier.


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/ac0d1c1d
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/ac0d1c1d
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/ac0d1c1d

Branch: refs/heads/camel-2.11.x
Commit: ac0d1c1dc6da0f12f901fcad83f616b54797f765
Parents: dd836f7
Author: Claus Ibsen <davsclaus@apache.org>
Authored: Thu Aug 15 15:27:36 2013 +0200
Committer: Claus Ibsen <davsclaus@apache.org>
Committed: Thu Aug 15 15:28:11 2013 +0200

----------------------------------------------------------------------
 .../component/jetty/JettyHttpComponent.java     | 53 ++++++++++++++++++++
 1 file changed, 53 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/ac0d1c1d/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java
----------------------------------------------------------------------
diff --git a/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java
b/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java
index e679485..a104197 100644
--- a/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java
+++ b/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java
@@ -100,7 +100,10 @@ public class JettyHttpComponent extends HttpComponent {
     protected Long continuationTimeout;
     protected boolean useContinuation = true;
     protected SSLContextParameters sslContextParameters;
+    protected Integer requestBufferSize;
+    protected Integer requestHeaderSize;
     protected Integer responseBufferSize;
+    protected Integer responseHeaderSize;
 
     class ConnectorRef {
         Server server;
@@ -542,6 +545,19 @@ public class JettyHttpComponent extends HttpComponent {
                     + " Unknown parameters=[" + properties + "]");
             }
         }
+
+        if (answer != null && requestBufferSize != null) {
+            answer.setRequestBufferSize(requestBufferSize);
+        }
+        if (answer != null && requestHeaderSize != null) {
+            answer.setRequestHeaderSize(requestHeaderSize);
+        }
+        if (answer != null && responseBufferSize != null) {
+            answer.setResponseBufferSize(responseBufferSize);
+        }
+        if (answer != null && responseHeaderSize != null) {
+            answer.setResponseBufferSize(responseHeaderSize);
+        }
         return answer;
     }
     
@@ -619,6 +635,19 @@ public class JettyHttpComponent extends HttpComponent {
                     + " Unknown parameters=[" + properties + "]");
             }
         }
+
+        if (requestBufferSize != null) {
+            answer.setRequestBufferSize(requestBufferSize);
+        }
+        if (requestHeaderSize != null) {
+            answer.setRequestHeaderSize(requestHeaderSize);
+        }
+        if (responseBufferSize != null) {
+            answer.setResponseBufferSize(responseBufferSize);
+        }
+        if (responseHeaderSize != null) {
+            answer.setResponseBufferSize(responseHeaderSize);
+        }
         return answer;
     }
 
@@ -838,6 +867,30 @@ public class JettyHttpComponent extends HttpComponent {
         this.responseBufferSize = responseBufferSize;
     }
 
+    public Integer getRequestBufferSize() {
+        return requestBufferSize;
+    }
+
+    public void setRequestBufferSize(Integer requestBufferSize) {
+        this.requestBufferSize = requestBufferSize;
+    }
+
+    public Integer getRequestHeaderSize() {
+        return requestHeaderSize;
+    }
+
+    public void setRequestHeaderSize(Integer requestHeaderSize) {
+        this.requestHeaderSize = requestHeaderSize;
+    }
+
+    public Integer getResponseHeaderSize() {
+        return responseHeaderSize;
+    }
+
+    public void setResponseHeaderSize(Integer responseHeaderSize) {
+        this.responseHeaderSize = responseHeaderSize;
+    }
+
     // Implementation methods
     // -------------------------------------------------------------------------
     protected CamelServlet createServletForConnector(Server server, Connector connector,


Mime
View raw message