You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by ga...@apache.org on 2015/08/28 11:50:59 UTC
[1/5] stratos git commit: deleting das monitoring artifacts
Repository: stratos
Updated Branches:
refs/heads/tenant-isolation 573b70380 -> 1156a56e5
deleting das monitoring artifacts
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/0770ff10
Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/0770ff10
Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/0770ff10
Branch: refs/heads/tenant-isolation
Commit: 0770ff10f4d7a9b3582cdc033a5cdd52afc0d5c3
Parents: 260f738
Author: Thanuja <th...@wso2.com>
Authored: Fri Aug 21 18:45:08 2015 +0530
Committer: Thanuja <th...@wso2.com>
Committed: Fri Aug 21 18:45:08 2015 +0530
----------------------------------------------------------------------
.../HealthStatsEventFormatter.xml | 30 -------------------
.../eventformatters/RIFEventFormatter.xml | 31 --------------------
.../DASDefaultWSO2EventOutputAdaptor.xml | 29 ------------------
3 files changed, 90 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/stratos/blob/0770ff10/extensions/cep/artifacts/eventformatters/HealthStatsEventFormatter.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/artifacts/eventformatters/HealthStatsEventFormatter.xml b/extensions/cep/artifacts/eventformatters/HealthStatsEventFormatter.xml
deleted file mode 100644
index bcef15f..0000000
--- a/extensions/cep/artifacts/eventformatters/HealthStatsEventFormatter.xml
+++ /dev/null
@@ -1,30 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
-
- Licensed to the Apache Software Foundation (ASF) under one
- or more contributor license agreements. See the NOTICE file
- distributed with this work for additional information
- regarding copyright ownership. The ASF licenses this file
- to you under the Apache License, Version 2.0 (the
- "License"); you may not use this file except in compliance
- with the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing,
- software distributed under the License is distributed on an
- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- KIND, either express or implied. See the License for the
- specific language governing permissions and limitations
- under the License.
-
--->
-<eventFormatter name="HealthStatsEventFormatter"
- statistics="disable" trace="enable" xmlns="http://wso2.org/carbon/eventformatter">
- <from streamName="cartridge_agent_health_stats" version="1.0.0"/>
- <mapping customMapping="disable" type="wso2event"/>
- <to eventAdaptorName="DASDefaultWSO2EventOutputAdaptor" eventAdaptorType="wso2event">
- <property name="stream">cartridge_agent_health_stats</property>
- <property name="version">1.0.0</property>
- </to>
-</eventFormatter>
http://git-wip-us.apache.org/repos/asf/stratos/blob/0770ff10/extensions/cep/artifacts/eventformatters/RIFEventFormatter.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/artifacts/eventformatters/RIFEventFormatter.xml b/extensions/cep/artifacts/eventformatters/RIFEventFormatter.xml
deleted file mode 100644
index 3cfd4a9..0000000
--- a/extensions/cep/artifacts/eventformatters/RIFEventFormatter.xml
+++ /dev/null
@@ -1,31 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
-
- Licensed to the Apache Software Foundation (ASF) under one
- or more contributor license agreements. See the NOTICE file
- distributed with this work for additional information
- regarding copyright ownership. The ASF licenses this file
- to you under the Apache License, Version 2.0 (the
- "License"); you may not use this file except in compliance
- with the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing,
- software distributed under the License is distributed on an
- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- KIND, either express or implied. See the License for the
- specific language governing permissions and limitations
- under the License.
-
--->
-<eventFormatter name="RIFEventFormatter" statistics="disable"
- trace="enable" xmlns="http://wso2.org/carbon/eventformatter">
- <from streamName="in_flight_requests" version="1.0.0"/>
- <mapping customMapping="disable" type="wso2event"/>
- <to eventAdaptorName="DASDefaultWSO2EventOutputAdaptor" eventAdaptorType="wso2event">
- <property name="stream">in_flight_requests</property>
- <property name="version">1.0.0</property>
- </to>
-</eventFormatter>
-
http://git-wip-us.apache.org/repos/asf/stratos/blob/0770ff10/extensions/cep/artifacts/outputeventadaptors/DASDefaultWSO2EventOutputAdaptor.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/artifacts/outputeventadaptors/DASDefaultWSO2EventOutputAdaptor.xml b/extensions/cep/artifacts/outputeventadaptors/DASDefaultWSO2EventOutputAdaptor.xml
deleted file mode 100755
index 6dad7a0..0000000
--- a/extensions/cep/artifacts/outputeventadaptors/DASDefaultWSO2EventOutputAdaptor.xml
+++ /dev/null
@@ -1,29 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
-
- Licensed to the Apache Software Foundation (ASF) under one
- or more contributor license agreements. See the NOTICE file
- distributed with this work for additional information
- regarding copyright ownership. The ASF licenses this file
- to you under the Apache License, Version 2.0 (the
- "License"); you may not use this file except in compliance
- with the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing,
- software distributed under the License is distributed on an
- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- KIND, either express or implied. See the License for the
- specific language governing permissions and limitations
- under the License.
-
--->
-<outputEventAdaptor name="DASDefaultWSO2EventOutputAdaptor"
- statistics="disable" trace="disable" type="wso2event"
- xmlns="http://wso2.org/carbon/eventadaptormanager">
- <property name="username">admin</property>
- <property name="receiverURL">tcp://localhost:7611</property>
- <property name="password">admin</property>
- <property name="authenticatorURL">ssl://localhost:7711</property>
-</outputEventAdaptor>
[3/5] stratos git commit: Disabling DAS thrift stats publisher
Posted by ga...@apache.org.
Disabling DAS thrift stats publisher
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/f10b71ec
Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/f10b71ec
Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/f10b71ec
Branch: refs/heads/tenant-isolation
Commit: f10b71ec3055c25e5faf4d86bf005dc11f622b39
Parents: 65b1b2a
Author: Thanuja <th...@wso2.com>
Authored: Sat Aug 22 22:58:25 2015 +0530
Committer: Thanuja <th...@wso2.com>
Committed: Sat Aug 22 22:58:25 2015 +0530
----------------------------------------------------------------------
products/stratos/conf/thrift-client-config.xml | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/stratos/blob/f10b71ec/products/stratos/conf/thrift-client-config.xml
----------------------------------------------------------------------
diff --git a/products/stratos/conf/thrift-client-config.xml b/products/stratos/conf/thrift-client-config.xml
index e5ea9c8..f730c42 100644
--- a/products/stratos/conf/thrift-client-config.xml
+++ b/products/stratos/conf/thrift-client-config.xml
@@ -30,7 +30,7 @@
</config>
<config>
<name>das</name>
- <statsPublisherEnabled>true</statsPublisherEnabled>
+ <statsPublisherEnabled>false</statsPublisherEnabled>
<username>admin</username>
<password>admin</password>
<ip>localhost</ip>
[5/5] stratos git commit: Merge branch 'tenant-isolation' of
https://github.com/Thanu/stratos into tenant-isolation
Posted by ga...@apache.org.
Merge branch 'tenant-isolation' of https://github.com/Thanu/stratos into tenant-isolation
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/1156a56e
Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/1156a56e
Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/1156a56e
Branch: refs/heads/tenant-isolation
Commit: 1156a56e591f7119fb304c67ce7c53fc267b7e9b
Parents: 7194cb6 f10b71e
Author: gayangunarathne <ga...@wso2.com>
Authored: Fri Aug 28 15:04:13 2015 +0530
Committer: gayangunarathne <ga...@wso2.com>
Committed: Fri Aug 28 15:04:13 2015 +0530
----------------------------------------------------------------------
.../publisher/ThriftClientConfigParser.java | 9 ++++--
.../statistics/publisher/ThriftClientInfo.java | 8 +++++
.../publisher/ThriftStatisticsPublisher.java | 6 ++--
.../cep/WSO2CEPHealthStatisticsPublisher.java | 3 +-
.../cep/WSO2CEPInFlightRequestPublisher.java | 3 +-
.../test/ThriftClientConfigParserTest.java | 2 ++
.../src/test/resources/thrift-client-config.xml | 2 ++
.../HealthStatsEventFormatter.xml | 30 -------------------
.../eventformatters/RIFEventFormatter.xml | 31 --------------------
.../DASDefaultWSO2EventOutputAdaptor.xml | 29 ------------------
products/stratos/conf/thrift-client-config.xml | 2 ++
11 files changed, 25 insertions(+), 100 deletions(-)
----------------------------------------------------------------------
[4/5] stratos git commit: merge with master branch
Posted by ga...@apache.org.
merge with master branch
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/7194cb66
Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/7194cb66
Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/7194cb66
Branch: refs/heads/tenant-isolation
Commit: 7194cb66e16504b116ea4d45a594dbfa053e0c1b
Parents: 573b703
Author: gayangunarathne <ga...@wso2.com>
Authored: Fri Aug 28 15:03:10 2015 +0530
Committer: gayangunarathne <ga...@wso2.com>
Committed: Fri Aug 28 15:03:10 2015 +0530
----------------------------------------------------------------------
.../tests/application/GroupTerminationBehaviorTest.java | 5 -----
1 file changed, 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/stratos/blob/7194cb66/products/stratos/modules/integration/src/test/java/org/apache/stratos/integration/tests/application/GroupTerminationBehaviorTest.java
----------------------------------------------------------------------
diff --git a/products/stratos/modules/integration/src/test/java/org/apache/stratos/integration/tests/application/GroupTerminationBehaviorTest.java b/products/stratos/modules/integration/src/test/java/org/apache/stratos/integration/tests/application/GroupTerminationBehaviorTest.java
index cbc5a65..475ddd4 100644
--- a/products/stratos/modules/integration/src/test/java/org/apache/stratos/integration/tests/application/GroupTerminationBehaviorTest.java
+++ b/products/stratos/modules/integration/src/test/java/org/apache/stratos/integration/tests/application/GroupTerminationBehaviorTest.java
@@ -160,11 +160,6 @@ public class GroupTerminationBehaviorTest extends StratosTestServerManager {
clusterIds.add(clusterIdC4);
clusterIds.add(clusterIdC2);
- assertGroupInactive(groupId, clusterIdC3);
-
- assertTerminatingOfNodes(groupId, clusterIds);
-
- assertTerminationOfNodes(groupId, clusterIds);
//Application active handling
topologyHandler.assertApplicationStatus(bean.getApplicationId(),
[2/5] stratos git commit: Adding statsPublisherEnabled element to
thrift-client-config.xml
Posted by ga...@apache.org.
Adding statsPublisherEnabled element to thrift-client-config.xml
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/65b1b2ac
Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/65b1b2ac
Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/65b1b2ac
Branch: refs/heads/tenant-isolation
Commit: 65b1b2ac2089cdaa806a393fd057c73e30ca83be
Parents: 0770ff1
Author: Thanuja <th...@wso2.com>
Authored: Thu Aug 20 13:49:02 2015 +0530
Committer: Thanuja <th...@wso2.com>
Committed: Fri Aug 21 18:45:13 2015 +0530
----------------------------------------------------------------------
.../statistics/publisher/ThriftClientConfigParser.java | 9 +++++++--
.../common/statistics/publisher/ThriftClientInfo.java | 8 ++++++++
.../statistics/publisher/ThriftStatisticsPublisher.java | 6 ++----
.../wso2/cep/WSO2CEPHealthStatisticsPublisher.java | 3 +--
.../publisher/wso2/cep/WSO2CEPInFlightRequestPublisher.java | 3 +--
.../stratos/common/test/ThriftClientConfigParserTest.java | 2 ++
.../src/test/resources/thrift-client-config.xml | 2 ++
products/stratos/conf/thrift-client-config.xml | 2 ++
8 files changed, 25 insertions(+), 10 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/stratos/blob/65b1b2ac/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/ThriftClientConfigParser.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/ThriftClientConfigParser.java b/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/ThriftClientConfigParser.java
index e2684ac..361b56a 100644
--- a/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/ThriftClientConfigParser.java
+++ b/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/ThriftClientConfigParser.java
@@ -40,6 +40,7 @@ public class ThriftClientConfigParser {
* Fields to be read from the thrift-client-config.xml file
*/
private static final String NAME_ELEMENT = "name";
+ private static final String STATS_PUBLISHER_ENABLED = "statsPublisherEnabled";
private static final String USERNAME_ELEMENT = "username";
private static final String PASSWORD_ELEMENT = "password";
private static final String IP_ELEMENT = "ip";
@@ -79,6 +80,7 @@ public class ThriftClientConfigParser {
SecretResolver secretResolver = SecretResolverFactory.create(document, false);
String nameValuesStr = null;
+ boolean statsPublisherEnabled;
String userNameValuesStr = null;
String passwordValueStr = null;
String ipValuesStr = null;
@@ -93,11 +95,9 @@ public class ThriftClientConfigParser {
OMElement thriftClientConfig = (OMElement) thriftClientIterator.next();
Iterator thriftClientConfigIterator = thriftClientConfig.getChildElements();
ThriftClientInfo thriftClientInfo = new ThriftClientInfo();
- log.info("Client Config: " + thriftClientConfigIterator.toString());
while (thriftClientConfigIterator.hasNext()) {
OMElement thriftClientConfigElement = (OMElement) thriftClientConfigIterator.next();
- log.info("Client Config Element: " + thriftClientConfigElement);
if (NAME_ELEMENT.equals(thriftClientConfigElement.getQName().getLocalPart())) {
nameValuesStr = thriftClientConfigElement.getText();
@@ -108,6 +108,11 @@ public class ThriftClientConfigParser {
}
}
+ if (STATS_PUBLISHER_ENABLED.equals(thriftClientConfigElement.getQName().getLocalPart())) {
+ statsPublisherEnabled = Boolean.parseBoolean(thriftClientConfigElement.getText());
+ thriftClientInfo.setStatsPublisherEnabled(statsPublisherEnabled);
+ }
+
if (USERNAME_ELEMENT.equals(thriftClientConfigElement.getQName().getLocalPart())) {
userNameValuesStr = thriftClientConfigElement.getText();
thriftClientInfo.setUsername(userNameValuesStr);
http://git-wip-us.apache.org/repos/asf/stratos/blob/65b1b2ac/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/ThriftClientInfo.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/ThriftClientInfo.java b/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/ThriftClientInfo.java
index 514d907..162c04f 100644
--- a/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/ThriftClientInfo.java
+++ b/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/ThriftClientInfo.java
@@ -23,11 +23,19 @@ package org.apache.stratos.common.statistics.publisher;
* Thrift Client Info
*/
public class ThriftClientInfo {
+ private boolean statsPublisherEnabled;
private String username;
private String password;
private String ip;
private String port;
+ public boolean isStatsPublisherEnabled() {
+ return statsPublisherEnabled;
+ }
+
+ public void setStatsPublisherEnabled(boolean statsPublisherEnabled) {
+ this.statsPublisherEnabled = statsPublisherEnabled;
+ }
public String getUsername() {
return username;
http://git-wip-us.apache.org/repos/asf/stratos/blob/65b1b2ac/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/ThriftStatisticsPublisher.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/ThriftStatisticsPublisher.java b/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/ThriftStatisticsPublisher.java
index 9242e41..151137e 100644
--- a/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/ThriftStatisticsPublisher.java
+++ b/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/ThriftStatisticsPublisher.java
@@ -50,21 +50,19 @@ public class ThriftStatisticsPublisher implements StatisticsPublisher {
* is parsed and assigned into ip,port,username and password fields
*
* @param streamDefinition Thrift Event Stream Definition
- * @param statsPublisherEnabled Whether thrift statistics publisher is enabled
* @param thriftClientName Thrift Client Name
*/
- public ThriftStatisticsPublisher(StreamDefinition streamDefinition, String statsPublisherEnabled,
- String thriftClientName) {
+ public ThriftStatisticsPublisher(StreamDefinition streamDefinition, String thriftClientName) {
ThriftClientConfig thriftClientConfig = ThriftClientConfig.getInstance();
ThriftClientInfo thriftClientInfo = thriftClientConfig.getThriftClientInfo(thriftClientName);
this.streamDefinition = streamDefinition;
+ this.enabled = thriftClientInfo.isStatsPublisherEnabled();
this.ip = thriftClientInfo.getIp();
this.port = thriftClientInfo.getPort();
this.username = thriftClientInfo.getUsername();
this.password = thriftClientInfo.getPassword();
- enabled = Boolean.getBoolean(statsPublisherEnabled);
if (enabled) {
init();
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/65b1b2ac/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/wso2/cep/WSO2CEPHealthStatisticsPublisher.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/wso2/cep/WSO2CEPHealthStatisticsPublisher.java b/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/wso2/cep/WSO2CEPHealthStatisticsPublisher.java
index f98e46c..fbc4030 100644
--- a/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/wso2/cep/WSO2CEPHealthStatisticsPublisher.java
+++ b/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/wso2/cep/WSO2CEPHealthStatisticsPublisher.java
@@ -37,13 +37,12 @@ public class WSO2CEPHealthStatisticsPublisher extends ThriftStatisticsPublisher
private static final Log log = LogFactory.getLog(WSO2CEPHealthStatisticsPublisher.class);
- private static final String STATS_PUBLISHER_ENABLED = "cep.stats.publisher.enabled";
private static final String DATA_STREAM_NAME = "cartridge_agent_health_stats";
private static final String VERSION = "1.0.0";
private static final String CEP_THRIFT_CLIENT_NAME = "cep";
public WSO2CEPHealthStatisticsPublisher() {
- super(createStreamDefinition(), STATS_PUBLISHER_ENABLED, CEP_THRIFT_CLIENT_NAME);
+ super(createStreamDefinition(), CEP_THRIFT_CLIENT_NAME);
}
private static StreamDefinition createStreamDefinition() {
http://git-wip-us.apache.org/repos/asf/stratos/blob/65b1b2ac/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/wso2/cep/WSO2CEPInFlightRequestPublisher.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/wso2/cep/WSO2CEPInFlightRequestPublisher.java b/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/wso2/cep/WSO2CEPInFlightRequestPublisher.java
index 4780a3d..9114074 100644
--- a/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/wso2/cep/WSO2CEPInFlightRequestPublisher.java
+++ b/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/wso2/cep/WSO2CEPInFlightRequestPublisher.java
@@ -39,13 +39,12 @@ import java.util.List;
public class WSO2CEPInFlightRequestPublisher extends ThriftStatisticsPublisher implements InFlightRequestPublisher {
private static final Log log = LogFactory.getLog(WSO2CEPInFlightRequestPublisher.class);
- private static final String STATS_PUBLISHER_ENABLED = "cep.stats.publisher.enabled";
private static final String DATA_STREAM_NAME = "in_flight_requests";
private static final String VERSION = "1.0.0";
private static final String CEP_THRIFT_CLIENT_NAME = "cep";
public WSO2CEPInFlightRequestPublisher() {
- super(createStreamDefinition(), STATS_PUBLISHER_ENABLED, CEP_THRIFT_CLIENT_NAME);
+ super(createStreamDefinition(), CEP_THRIFT_CLIENT_NAME);
}
private static StreamDefinition createStreamDefinition() {
http://git-wip-us.apache.org/repos/asf/stratos/blob/65b1b2ac/components/org.apache.stratos.common/src/test/java/org/apache/stratos/common/test/ThriftClientConfigParserTest.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.common/src/test/java/org/apache/stratos/common/test/ThriftClientConfigParserTest.java b/components/org.apache.stratos.common/src/test/java/org/apache/stratos/common/test/ThriftClientConfigParserTest.java
index c51fa7e..1627c40 100644
--- a/components/org.apache.stratos.common/src/test/java/org/apache/stratos/common/test/ThriftClientConfigParserTest.java
+++ b/components/org.apache.stratos.common/src/test/java/org/apache/stratos/common/test/ThriftClientConfigParserTest.java
@@ -47,11 +47,13 @@ public class ThriftClientConfigParserTest extends TestCase {
ThriftClientInfo dasThriftClientInfo = thriftClientConfig.getThriftClientInfo(
ThriftClientConfig.DAS_THRIFT_CLIENT_NAME);
+ assertEquals("CEP Stats Publisher not enabled",true,cepThriftClientInfo.isStatsPublisherEnabled());
assertEquals("Incorrect Username", "admin", cepThriftClientInfo.getUsername());
assertEquals("Incorrect Password", "1234", cepThriftClientInfo.getPassword());
assertEquals("Incorrect IP", "192.168.10.10", cepThriftClientInfo.getIp());
assertEquals("Incorrect Port", "9300", cepThriftClientInfo.getPort());
+ assertEquals("DAS Stats Publisher not enabled",true,dasThriftClientInfo.isStatsPublisherEnabled());
assertEquals("Incorrect Username", "admin1", dasThriftClientInfo.getUsername());
assertEquals("Incorrect Password", "12345", dasThriftClientInfo.getPassword());
assertEquals("Incorrect IP", "192.168.10.11", dasThriftClientInfo.getIp());
http://git-wip-us.apache.org/repos/asf/stratos/blob/65b1b2ac/components/org.apache.stratos.common/src/test/resources/thrift-client-config.xml
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.common/src/test/resources/thrift-client-config.xml b/components/org.apache.stratos.common/src/test/resources/thrift-client-config.xml
index 80d5796..8b10756 100644
--- a/components/org.apache.stratos.common/src/test/resources/thrift-client-config.xml
+++ b/components/org.apache.stratos.common/src/test/resources/thrift-client-config.xml
@@ -22,6 +22,7 @@
<thriftClientConfiguration>
<config>
<name>cep</name>
+ <statsPublisherEnabled>true</statsPublisherEnabled>
<username>admin</username>
<password>1234</password>
<ip>192.168.10.10</ip>
@@ -29,6 +30,7 @@
</config>
<config>
<name>das</name>
+ <statsPublisherEnabled>true</statsPublisherEnabled>
<username>admin1</username>
<password>12345</password>
<ip>192.168.10.11</ip>
http://git-wip-us.apache.org/repos/asf/stratos/blob/65b1b2ac/products/stratos/conf/thrift-client-config.xml
----------------------------------------------------------------------
diff --git a/products/stratos/conf/thrift-client-config.xml b/products/stratos/conf/thrift-client-config.xml
index 4b3b5b9..e5ea9c8 100644
--- a/products/stratos/conf/thrift-client-config.xml
+++ b/products/stratos/conf/thrift-client-config.xml
@@ -22,6 +22,7 @@
<thriftClientConfiguration>
<config>
<name>cep</name>
+ <statsPublisherEnabled>true</statsPublisherEnabled>
<username>admin</username>
<password>admin</password>
<ip>localhost</ip>
@@ -29,6 +30,7 @@
</config>
<config>
<name>das</name>
+ <statsPublisherEnabled>true</statsPublisherEnabled>
<username>admin</username>
<password>admin</password>
<ip>localhost</ip>