Updated Branches: refs/heads/master e178cc2b7 -> f8bd48ac0
Optimized imports and formatted code in load balancer common Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/6708f8aa Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/6708f8aa Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/6708f8aa Branch: refs/heads/master Commit: 6708f8aa30a9b8eca038f0d846c59047bd69004a Parents: cd15108 Author: Imesh Gunaratne <[email protected]> Authored: Wed Dec 11 11:44:20 2013 +0530 Committer: Imesh Gunaratne <[email protected]> Committed: Wed Dec 11 11:44:20 2013 +0530 ---------------------------------------------------------------------- .../common/internal/LoadBalancerCommonServiceComponent.java | 2 +- .../balancer/common/statistics/LoadBalancerStatsPublisher.java | 4 ++-- .../common/statistics/WSO2CEPFaultyMemberPublisher.java | 6 +++--- .../common/statistics/WSO2CEPInFlightRequestPublisher.java | 5 ++--- .../load/balancer/common/statistics/WSO2CEPStatsPublisher.java | 3 --- 5 files changed, 8 insertions(+), 12 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/6708f8aa/components/org.apache.stratos.load.balancer.common/src/main/java/org/apache/stratos/load/balancer/common/internal/LoadBalancerCommonServiceComponent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.load.balancer.common/src/main/java/org/apache/stratos/load/balancer/common/internal/LoadBalancerCommonServiceComponent.java b/components/org.apache.stratos.load.balancer.common/src/main/java/org/apache/stratos/load/balancer/common/internal/LoadBalancerCommonServiceComponent.java index 2081f99..3b9e7f0 100644 --- a/components/org.apache.stratos.load.balancer.common/src/main/java/org/apache/stratos/load/balancer/common/internal/LoadBalancerCommonServiceComponent.java +++ b/components/org.apache.stratos.load.balancer.common/src/main/java/org/apache/stratos/load/balancer/common/internal/LoadBalancerCommonServiceComponent.java @@ -36,7 +36,7 @@ public class LoadBalancerCommonServiceComponent { protected void activate(ComponentContext context) { try { - if(log.isDebugEnabled()) { + if (log.isDebugEnabled()) { log.debug("Load Balancer Common Service bundle activated"); } } catch (Exception e) { http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/6708f8aa/components/org.apache.stratos.load.balancer.common/src/main/java/org/apache/stratos/load/balancer/common/statistics/LoadBalancerStatsPublisher.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.load.balancer.common/src/main/java/org/apache/stratos/load/balancer/common/statistics/LoadBalancerStatsPublisher.java b/components/org.apache.stratos.load.balancer.common/src/main/java/org/apache/stratos/load/balancer/common/statistics/LoadBalancerStatsPublisher.java index 298087a..e6f8117 100644 --- a/components/org.apache.stratos.load.balancer.common/src/main/java/org/apache/stratos/load/balancer/common/statistics/LoadBalancerStatsPublisher.java +++ b/components/org.apache.stratos.load.balancer.common/src/main/java/org/apache/stratos/load/balancer/common/statistics/LoadBalancerStatsPublisher.java @@ -19,8 +19,6 @@ package org.apache.stratos.load.balancer.common.statistics; -import java.util.Map; - /** * Load balancer statistics publisher interface. */ @@ -28,6 +26,7 @@ public interface LoadBalancerStatsPublisher { /** * Set statistics publisher enabled or disabled. + * * @param enabled */ void setEnabled(boolean enabled); @@ -39,6 +38,7 @@ public interface LoadBalancerStatsPublisher { /** * Payload to be published. + * * @param payload An array of parameter values. */ void publish(Object[] payload); http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/6708f8aa/components/org.apache.stratos.load.balancer.common/src/main/java/org/apache/stratos/load/balancer/common/statistics/WSO2CEPFaultyMemberPublisher.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.load.balancer.common/src/main/java/org/apache/stratos/load/balancer/common/statistics/WSO2CEPFaultyMemberPublisher.java b/components/org.apache.stratos.load.balancer.common/src/main/java/org/apache/stratos/load/balancer/common/statistics/WSO2CEPFaultyMemberPublisher.java index fc6b65a..3225987 100644 --- a/components/org.apache.stratos.load.balancer.common/src/main/java/org/apache/stratos/load/balancer/common/statistics/WSO2CEPFaultyMemberPublisher.java +++ b/components/org.apache.stratos.load.balancer.common/src/main/java/org/apache/stratos/load/balancer/common/statistics/WSO2CEPFaultyMemberPublisher.java @@ -28,7 +28,7 @@ import java.util.List; /** * WSO2 CEP faulty member publisher. - * + * <p/> * Faulty members: * If a request was rejected by some of the members in a cluster while at least * one member could serve it, those members could be identified as faulty. @@ -49,8 +49,7 @@ public class WSO2CEPFaultyMemberPublisher extends WSO2CEPStatsPublisher { payloadData.add(new Attribute("member_id", AttributeType.STRING)); streamDefinition.setPayloadData(payloadData); return streamDefinition; - } - catch (Exception e) { + } catch (Exception e) { throw new RuntimeException("Could not create stream definition", e); } } @@ -61,6 +60,7 @@ public class WSO2CEPFaultyMemberPublisher extends WSO2CEPStatsPublisher { /** * Publish faulty members. + * * @param clusterId * @param memberId */ http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/6708f8aa/components/org.apache.stratos.load.balancer.common/src/main/java/org/apache/stratos/load/balancer/common/statistics/WSO2CEPInFlightRequestPublisher.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.load.balancer.common/src/main/java/org/apache/stratos/load/balancer/common/statistics/WSO2CEPInFlightRequestPublisher.java b/components/org.apache.stratos.load.balancer.common/src/main/java/org/apache/stratos/load/balancer/common/statistics/WSO2CEPInFlightRequestPublisher.java index 523587d..b8804d2 100644 --- a/components/org.apache.stratos.load.balancer.common/src/main/java/org/apache/stratos/load/balancer/common/statistics/WSO2CEPInFlightRequestPublisher.java +++ b/components/org.apache.stratos.load.balancer.common/src/main/java/org/apache/stratos/load/balancer/common/statistics/WSO2CEPInFlightRequestPublisher.java @@ -28,7 +28,7 @@ import java.util.List; /** * WSO2 CEP in flight request count publisher. - * + * <p/> * In-flight request count: * Number of requests being served at a given moment could be identified as in-flight request count. */ @@ -49,8 +49,7 @@ public class WSO2CEPInFlightRequestPublisher extends WSO2CEPStatsPublisher { payloadData.add(new Attribute("in_flight_request_count", AttributeType.INT)); streamDefinition.setPayloadData(payloadData); return streamDefinition; - } - catch (Exception e) { + } catch (Exception e) { throw new RuntimeException("Could not create stream definition", e); } } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/6708f8aa/components/org.apache.stratos.load.balancer.common/src/main/java/org/apache/stratos/load/balancer/common/statistics/WSO2CEPStatsPublisher.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.load.balancer.common/src/main/java/org/apache/stratos/load/balancer/common/statistics/WSO2CEPStatsPublisher.java b/components/org.apache.stratos.load.balancer.common/src/main/java/org/apache/stratos/load/balancer/common/statistics/WSO2CEPStatsPublisher.java index 6d013ed..03df6f2 100644 --- a/components/org.apache.stratos.load.balancer.common/src/main/java/org/apache/stratos/load/balancer/common/statistics/WSO2CEPStatsPublisher.java +++ b/components/org.apache.stratos.load.balancer.common/src/main/java/org/apache/stratos/load/balancer/common/statistics/WSO2CEPStatsPublisher.java @@ -28,11 +28,8 @@ import org.wso2.carbon.databridge.agent.thrift.conf.AgentConfiguration; import org.wso2.carbon.databridge.agent.thrift.exception.AgentException; import org.wso2.carbon.databridge.commons.Event; import org.wso2.carbon.databridge.commons.StreamDefinition; -import org.wso2.carbon.utils.CarbonUtils; -import java.io.File; import java.util.HashMap; -import java.util.Map; /** * WSO2 CEP statistics publisher for the load balancer.
