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/051b24c5 Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/051b24c5 Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/051b24c5 Branch: refs/heads/stratos-4.1.x Commit: 051b24c5b952872300e669a08a6db745b8b9026a Parents: fe640c6 Author: Isuru Haththotuwa <[email protected]> Authored: Fri Dec 25 13:48:23 2015 +0530 Committer: Isuru Haththotuwa <[email protected]> Committed: Fri Dec 25 17:10:00 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/051b24c5/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 67258c3..08d75a4 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 @@ -47,7 +47,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 @@ -57,7 +57,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()) {
