Updated Branches: refs/heads/master 9edc9231f -> bafb6a57b
Fixed cep stats publisher enabled flag Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/3476c280 Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/3476c280 Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/3476c280 Branch: refs/heads/master Commit: 3476c280b1fac4cb85af1c9cd22a956c85936022 Parents: 5314c31 Author: Imesh Gunaratne <[email protected]> Authored: Fri Dec 20 15:46:53 2013 +0530 Committer: Imesh Gunaratne <[email protected]> Committed: Fri Dec 20 15:46:53 2013 +0530 ---------------------------------------------------------------------- .../statistics/publisher/WSO2CEPStatisticsPublisher.java | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/3476c280/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/WSO2CEPStatisticsPublisher.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/WSO2CEPStatisticsPublisher.java b/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/WSO2CEPStatisticsPublisher.java index 0899f1a..5db61cd 100644 --- a/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/WSO2CEPStatisticsPublisher.java +++ b/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/WSO2CEPStatisticsPublisher.java @@ -51,12 +51,10 @@ public class WSO2CEPStatisticsPublisher implements StatisticsPublisher { this.port = System.getProperty("thrift.receiver.port"); this.username = "admin"; this.password = "admin"; - String enabledStr = System.getProperty("cep.stats.publisher.enabled"); - if (StringUtils.isNotBlank(enabledStr)) { - enabled = Boolean.getBoolean(enabledStr); - if (enabled) { - init(); - } + + enabled = Boolean.getBoolean("cep.stats.publisher.enabled"); + if (enabled) { + init(); } }
