Updated Branches: refs/heads/camel-2.11.x 5c65c6ada -> 3a2dabb0e refs/heads/camel-2.12.x a862680c1 -> fdbdedd34
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/fdbdedd3 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/fdbdedd3 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/fdbdedd3 Branch: refs/heads/camel-2.12.x Commit: fdbdedd34f0e7fe0e53c539d97a71ed843310eb8 Parents: a862680 Author: Willem Jiang <willem.ji...@gmail.com> Authored: Thu Dec 19 17:09:24 2013 +0800 Committer: Willem Jiang <willem.ji...@gmail.com> Committed: Thu Dec 19 17:12:00 2013 +0800 ---------------------------------------------------------------------- .../component/restlet/RestletComponent.java | 25 ++++++++++++++++++++ 1 file changed, 25 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/fdbdedd3/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; + } }
