Updated Branches: refs/heads/master 90216eadc -> 40a5bfd00
Formatted code in health statistics publisher Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/40a5bfd0 Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/40a5bfd0 Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/40a5bfd0 Branch: refs/heads/master Commit: 40a5bfd0052365a81caec61777f3897031d4edec Parents: 90216ea Author: Imesh Gunaratne <[email protected]> Authored: Fri Dec 20 14:54:24 2013 +0530 Committer: Imesh Gunaratne <[email protected]> Committed: Fri Dec 20 14:54:24 2013 +0530 ---------------------------------------------------------------------- .../agent/statistics/publisher/HealthStatisticsPublisher.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/40a5bfd0/components/org.apache.stratos.cartridge.agent/src/main/java/org/apache/stratos/cartridge/agent/statistics/publisher/HealthStatisticsPublisher.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.cartridge.agent/src/main/java/org/apache/stratos/cartridge/agent/statistics/publisher/HealthStatisticsPublisher.java b/components/org.apache.stratos.cartridge.agent/src/main/java/org/apache/stratos/cartridge/agent/statistics/publisher/HealthStatisticsPublisher.java index e4f0ae8..4972a30 100644 --- a/components/org.apache.stratos.cartridge.agent/src/main/java/org/apache/stratos/cartridge/agent/statistics/publisher/HealthStatisticsPublisher.java +++ b/components/org.apache.stratos.cartridge.agent/src/main/java/org/apache/stratos/cartridge/agent/statistics/publisher/HealthStatisticsPublisher.java @@ -43,15 +43,14 @@ public class HealthStatisticsPublisher extends WSO2CEPStatisticsPublisher { StreamDefinition streamDefinition = new StreamDefinition(DATA_STREAM_NAME, VERSION); streamDefinition.setNickName("agent health stats"); streamDefinition.setDescription("agent health stats"); + // Payload definition List<Attribute> payloadData = new ArrayList<Attribute>(); - payloadData.add(new Attribute("cluster_id", AttributeType.STRING)); payloadData.add(new Attribute("network_partition_id", AttributeType.STRING)); payloadData.add(new Attribute("member_id", AttributeType.STRING)); payloadData.add(new Attribute("partition_id", AttributeType.STRING)); payloadData.add(new Attribute("health_description", AttributeType.STRING)); payloadData.add(new Attribute("value", AttributeType.DOUBLE)); - streamDefinition.setPayloadData(payloadData); return streamDefinition; } catch (Exception e) {
