Repository: stratos Updated Branches: refs/heads/stratos-4.1.x c251d5eb8 -> 8033fd38d
increasing event receiver default pool size to 25 Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/8033fd38 Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/8033fd38 Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/8033fd38 Branch: refs/heads/stratos-4.1.x Commit: 8033fd38d5909004a44909b9506126fd0a1201a8 Parents: c251d5e Author: Isuru Haththotuwa <[email protected]> Authored: Fri Dec 25 13:48:23 2015 +0530 Committer: Isuru Haththotuwa <[email protected]> Committed: Fri Dec 25 13:49:23 2015 +0530 ---------------------------------------------------------------------- .../stratos/messaging/message/receiver/StratosEventReceiver.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/8033fd38/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/StratosEventReceiver.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/StratosEventReceiver.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/StratosEventReceiver.java index 8c29816..7541133 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/StratosEventReceiver.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/StratosEventReceiver.java @@ -45,7 +45,7 @@ public abstract class StratosEventReceiver { // executor service used protected ExecutorService executorService; // pool size - protected static int threadPoolSize = 15; + protected static int threadPoolSize = 25; static { // check if the thread pool size is given as a system parameter @@ -55,7 +55,7 @@ public abstract class StratosEventReceiver { threadPoolSize = Integer.parseInt(poolSize); } catch (NumberFormatException e) { log.error("Invalid configuration found for StratosEventReceiver thread pool size", e); - threadPoolSize = 15; + threadPoolSize = 25; } } if (log.isDebugEnabled()) {
