You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2013/08/15 15:30:34 UTC
[3/3] git commit: CAMEL-6629: Configure jetty connector
request/response buffer sizes is easier.
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 <da...@apache.org>
Authored: Thu Aug 15 15:27:36 2013 +0200
Committer: Claus Ibsen <da...@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,