Repository: stratos Updated Branches: refs/heads/master c90eb9a72 -> 574c6d2a2
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/574c6d2a Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/574c6d2a Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/574c6d2a Branch: refs/heads/master Commit: 574c6d2a2f0c8d673b69a54fdf302280c6a3405b Parents: c90eb9a Author: Isuru Haththotuwa <[email protected]> Authored: Fri Dec 25 13:48:23 2015 +0530 Committer: Isuru Haththotuwa <[email protected]> Committed: Fri Dec 25 13:48: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/574c6d2a/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()) {
