You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2013/12/19 10:12:33 UTC
[2/2] git commit: CAMEL-7082 Supporting to set more work thread in
camel-restlet component
CAMEL-7082 Supporting to set more work thread in camel-restlet component
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/3a2dabb0
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/3a2dabb0
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/3a2dabb0
Branch: refs/heads/camel-2.11.x
Commit: 3a2dabb0ef6a21b187317d46f69e69af64dc4273
Parents: 5c65c6a
Author: Willem Jiang <wi...@gmail.com>
Authored: Thu Dec 19 17:09:24 2013 +0800
Committer: Willem Jiang <wi...@gmail.com>
Committed: Thu Dec 19 17:12:14 2013 +0800
----------------------------------------------------------------------
.../component/restlet/RestletComponent.java | 25 ++++++++++++++++++++
1 file changed, 25 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/3a2dabb0/components/camel-restlet/src/main/java/org/apache/camel/component/restlet/RestletComponent.java
----------------------------------------------------------------------
diff --git a/components/camel-restlet/src/main/java/org/apache/camel/component/restlet/RestletComponent.java b/components/camel-restlet/src/main/java/org/apache/camel/component/restlet/RestletComponent.java
index 720be3e..6eae3df 100644
--- a/components/camel-restlet/src/main/java/org/apache/camel/component/restlet/RestletComponent.java
+++ b/components/camel-restlet/src/main/java/org/apache/camel/component/restlet/RestletComponent.java
@@ -57,9 +57,11 @@ public class RestletComponent extends HeaderFilterStrategyComponent {
private Integer inboundBufferSize;
private Integer minThreads;
private Integer maxThreads;
+ private Integer lowThreads;
private Integer maxConnectionsPerHost;
private Integer maxTotalConnections;
private Integer outboundBufferSize;
+ private Integer maxQueued;
private Boolean persistingConnections;
private Boolean pipeliningConnections;
private Integer threadMaxIdleTimeMs;
@@ -237,6 +239,12 @@ public class RestletComponent extends HeaderFilterStrategyComponent {
if (getMaxThreads() != null) {
params.add("maxThreads", getMaxThreads().toString());
}
+ if (getLowThreads() != null) {
+ params.add("lowThreads", getLowThreads().toString());
+ }
+ if (getMaxQueued() != null) {
+ params.add("maxQueued", getMaxQueued().toString());
+ }
if (getMaxConnectionsPerHost() != null) {
params.add("maxConnectionsPerHost", getMaxConnectionsPerHost().toString());
}
@@ -261,6 +269,7 @@ public class RestletComponent extends HeaderFilterStrategyComponent {
if (getReuseAddress() != null) {
params.add("reuseAddress", getReuseAddress().toString());
}
+
LOG.debug("Setting parameters: {} to server: {}", params, server);
server.getContext().setParameters(params);
@@ -372,6 +381,14 @@ public class RestletComponent extends HeaderFilterStrategyComponent {
public void setMaxThreads(Integer maxThreads) {
this.maxThreads = maxThreads;
}
+
+ public Integer getLowThreads() {
+ return lowThreads;
+ }
+
+ public void setLowThreads(Integer lowThreads) {
+ this.lowThreads = lowThreads;
+ }
public Integer getMaxTotalConnections() {
return maxTotalConnections;
@@ -436,4 +453,12 @@ public class RestletComponent extends HeaderFilterStrategyComponent {
public void setReuseAddress(Boolean reuseAddress) {
this.reuseAddress = reuseAddress;
}
+
+ public Integer getMaxQueued() {
+ return maxQueued;
+ }
+
+ public void setMaxQueued(Integer maxQueued) {
+ this.maxQueued = maxQueued;
+ }
}