Return-Path: X-Original-To: apmail-camel-commits-archive@www.apache.org Delivered-To: apmail-camel-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 6FE3617E7F for ; Thu, 19 Feb 2015 07:12:54 +0000 (UTC) Received: (qmail 3255 invoked by uid 500); 19 Feb 2015 07:12:54 -0000 Delivered-To: apmail-camel-commits-archive@camel.apache.org Received: (qmail 3205 invoked by uid 500); 19 Feb 2015 07:12:54 -0000 Mailing-List: contact commits-help@camel.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@camel.apache.org Delivered-To: mailing list commits@camel.apache.org Received: (qmail 3129 invoked by uid 99); 19 Feb 2015 07:12:54 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 19 Feb 2015 07:12:54 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id D4E87E0664; Thu, 19 Feb 2015 07:12:53 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: davsclaus@apache.org To: commits@camel.apache.org Date: Thu, 19 Feb 2015 07:12:53 -0000 Message-Id: <2dbcd35a01704268b15309604c0bfd20@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [1/2] camel git commit: make the SWFActivityConsumer's thread pool size configurable via SWFConfiguration.activityThreadPoolSize - the default activity thread pool size is 100, as per the aws-java-sdk Repository: camel Updated Branches: refs/heads/master ac5b1a5c4 -> f98f5c581 make the SWFActivityConsumer's thread pool size configurable via SWFConfiguration.activityThreadPoolSize - the default activity thread pool size is 100, as per the aws-java-sdk Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/91457b8d Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/91457b8d Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/91457b8d Branch: refs/heads/master Commit: 91457b8daaa838bafe5b43eddff338618150ba99 Parents: ac5b1a5 Author: Steven Marcus Authored: Thu Feb 19 17:12:13 2015 +1100 Committer: Claus Ibsen Committed: Thu Feb 19 08:11:09 2015 +0100 ---------------------------------------------------------------------- .../apache/camel/component/aws/swf/SWFActivityConsumer.java | 1 + .../org/apache/camel/component/aws/swf/SWFConfiguration.java | 8 ++++++++ 2 files changed, 9 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/91457b8d/components/camel-aws/src/main/java/org/apache/camel/component/aws/swf/SWFActivityConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-aws/src/main/java/org/apache/camel/component/aws/swf/SWFActivityConsumer.java b/components/camel-aws/src/main/java/org/apache/camel/component/aws/swf/SWFActivityConsumer.java index 0f47606..d5dff14 100644 --- a/components/camel-aws/src/main/java/org/apache/camel/component/aws/swf/SWFActivityConsumer.java +++ b/components/camel-aws/src/main/java/org/apache/camel/component/aws/swf/SWFActivityConsumer.java @@ -51,6 +51,7 @@ public class SWFActivityConsumer extends DefaultConsumer { CamelActivityImplementationFactory factory = new CamelActivityImplementationFactory(this, configuration); genericWorker = new GenericActivityWorker(endpoint.getSWClient(), configuration.getDomainName(), configuration.getActivityList()); genericWorker.setActivityImplementationFactory(factory); + genericWorker.setTaskExecutorThreadPoolSize(configuration.getActivityThreadPoolSize()); genericWorker.start(); super.doStart(); } http://git-wip-us.apache.org/repos/asf/camel/blob/91457b8d/components/camel-aws/src/main/java/org/apache/camel/component/aws/swf/SWFConfiguration.java ---------------------------------------------------------------------- diff --git a/components/camel-aws/src/main/java/org/apache/camel/component/aws/swf/SWFConfiguration.java b/components/camel-aws/src/main/java/org/apache/camel/component/aws/swf/SWFConfiguration.java index 4036996..6c7db6d 100644 --- a/components/camel-aws/src/main/java/org/apache/camel/component/aws/swf/SWFConfiguration.java +++ b/components/camel-aws/src/main/java/org/apache/camel/component/aws/swf/SWFConfiguration.java @@ -75,6 +75,8 @@ public class SWFConfiguration { private ActivityTypeRegistrationOptions activityTypeRegistrationOptions; @UriParam private WorkflowTypeRegistrationOptions workflowTypeRegistrationOptions; + @UriParam + private int activityThreadPoolSize = 100; // aws-sdk default public String getAccessKey() { return accessKey; @@ -259,4 +261,10 @@ public class SWFConfiguration { public void setActivitySchedulingOptions(ActivitySchedulingOptions activitySchedulingOptions) { this.activitySchedulingOptions = activitySchedulingOptions; } + + public int getActivityThreadPoolSize() { return activityThreadPoolSize; } + + public void setActivityThreadPoolSize(int activityThreadPoolSize) { + this.activityThreadPoolSize = activityThreadPoolSize; + } }