Moving STATS_PUBLISHER_THREAD_POOL_SIZE to CloudControllerConstants to have common config for member status and info publishers
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/05d1c187 Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/05d1c187 Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/05d1c187 Branch: refs/heads/stratos-4.1.x Commit: 05d1c187e1aeb3efeef4c1d4f6282ea41de51d63 Parents: 609bc9d Author: Thanuja <[email protected]> Authored: Mon Nov 23 19:11:33 2015 +0530 Committer: Thanuja <[email protected]> Committed: Mon Nov 23 19:11:33 2015 +0530 ---------------------------------------------------------------------- .../statistics/publisher/DASMemberInformationPublisher.java | 3 +-- .../controller/statistics/publisher/DASMemberStatusPublisher.java | 3 +-- .../stratos/cloud/controller/util/CloudControllerConstants.java | 1 + 3 files changed, 3 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/05d1c187/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/statistics/publisher/DASMemberInformationPublisher.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/statistics/publisher/DASMemberInformationPublisher.java b/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/statistics/publisher/DASMemberInformationPublisher.java index 621f9e2..8107e1b 100644 --- a/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/statistics/publisher/DASMemberInformationPublisher.java +++ b/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/statistics/publisher/DASMemberInformationPublisher.java @@ -47,14 +47,13 @@ public class DASMemberInformationPublisher extends MemberInformationPublisher { private static final String DATA_STREAM_NAME = "member_info"; private static final String VERSION = "1.0.0"; private static final String DAS_THRIFT_CLIENT_NAME = "das"; - private static final int STATS_PUBLISHER_THREAD_POOL_SIZE = 10; private static final String VALUE_NOT_FOUND = "Value Not Found"; private ExecutorService executorService; private DASMemberInformationPublisher() { super(createStreamDefinition(), DAS_THRIFT_CLIENT_NAME); executorService = StratosThreadPool.getExecutorService(CloudControllerConstants.STATS_PUBLISHER_THREAD_POOL_ID, - STATS_PUBLISHER_THREAD_POOL_SIZE); + CloudControllerConstants.STATS_PUBLISHER_THREAD_POOL_SIZE); } public static DASMemberInformationPublisher getInstance() { http://git-wip-us.apache.org/repos/asf/stratos/blob/05d1c187/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/statistics/publisher/DASMemberStatusPublisher.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/statistics/publisher/DASMemberStatusPublisher.java b/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/statistics/publisher/DASMemberStatusPublisher.java index 7a291ab..6bb6251 100644 --- a/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/statistics/publisher/DASMemberStatusPublisher.java +++ b/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/statistics/publisher/DASMemberStatusPublisher.java @@ -41,13 +41,12 @@ public class DASMemberStatusPublisher extends MemberStatusPublisher { private static final String DATA_STREAM_NAME = "member_lifecycle"; private static final String VERSION = "1.0.0"; private static final String DAS_THRIFT_CLIENT_NAME = "das"; - private static final int STATS_PUBLISHER_THREAD_POOL_SIZE = 10; private ExecutorService executorService; private DASMemberStatusPublisher() { super(createStreamDefinition(), DAS_THRIFT_CLIENT_NAME); executorService = StratosThreadPool.getExecutorService(CloudControllerConstants.STATS_PUBLISHER_THREAD_POOL_ID, - STATS_PUBLISHER_THREAD_POOL_SIZE); + CloudControllerConstants.STATS_PUBLISHER_THREAD_POOL_SIZE); } public static DASMemberStatusPublisher getInstance() { http://git-wip-us.apache.org/repos/asf/stratos/blob/05d1c187/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/util/CloudControllerConstants.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/util/CloudControllerConstants.java b/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/util/CloudControllerConstants.java index ccd8d34..29facf0 100644 --- a/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/util/CloudControllerConstants.java +++ b/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/util/CloudControllerConstants.java @@ -163,6 +163,7 @@ public final class CloudControllerConstants { public static final String SCALING_DECISION_ID_COL = "scaling_decision_id"; public static final String STATS_PUBLISHER_THREAD_POOL_ID = "cloud.controller.stats.publisher.thread.pool"; + public static final int STATS_PUBLISHER_THREAD_POOL_SIZE = 10; /** * Properties
