You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by is...@apache.org on 2016/01/05 16:47:54 UTC

[45/50] [abbrv] stratos git commit: increasing event receiver default pool size to 25

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 <is...@apache.org>
Authored: Fri Dec 25 13:48:23 2015 +0530
Committer: Isuru Haththotuwa <is...@apache.org>
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()) {