Suppress warnings, fixing use of raw types etc.
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/dedea520 Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/dedea520 Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/dedea520 Branch: refs/heads/4.0.0-grouping Commit: dedea5205ff7d9cb36b07d67d371d75a5431cdf8 Parents: 36ffe22 Author: Nirmal Fernando <[email protected]> Authored: Wed Aug 20 09:11:42 2014 +0530 Committer: Nirmal Fernando <[email protected]> Committed: Wed Aug 20 09:11:42 2014 +0530 ---------------------------------------------------------------------- .../load/balancer/algorithm/LoadBalanceAlgorithmFactory.java | 2 +- .../apache/stratos/load/balancer/cache/AlgorithmContextCache.java | 3 ++- .../stratos/load/balancer/conf/LoadBalancerConfiguration.java | 2 -- .../stratos/load/balancer/context/LoadBalancerContextUtil.java | 3 ++- .../stratos/load/balancer/context/map/MemberIpHostnameMap.java | 3 ++- .../load/balancer/endpoint/TenantAwareLoadBalanceEndpoint.java | 2 +- .../balancer/statistics/InFlightRequestDecrementCallable.java | 2 +- .../balancer/statistics/InFlightRequestIncrementCallable.java | 2 +- 8 files changed, 10 insertions(+), 9 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/dedea520/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/algorithm/LoadBalanceAlgorithmFactory.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/algorithm/LoadBalanceAlgorithmFactory.java b/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/algorithm/LoadBalanceAlgorithmFactory.java index 1e64668..4eeb6f2 100644 --- a/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/algorithm/LoadBalanceAlgorithmFactory.java +++ b/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/algorithm/LoadBalanceAlgorithmFactory.java @@ -33,7 +33,7 @@ public class LoadBalanceAlgorithmFactory { public static LoadBalanceAlgorithm createAlgorithm(String className) { try { - Class algorithmClass = Class.forName(className); + Class<?> algorithmClass = Class.forName(className); try { Object instance = algorithmClass.getConstructor().newInstance(); if (instance instanceof LoadBalanceAlgorithm) { http://git-wip-us.apache.org/repos/asf/stratos/blob/dedea520/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/cache/AlgorithmContextCache.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/cache/AlgorithmContextCache.java b/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/cache/AlgorithmContextCache.java index 100bf53..746382a 100644 --- a/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/cache/AlgorithmContextCache.java +++ b/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/cache/AlgorithmContextCache.java @@ -30,7 +30,8 @@ import java.util.Map; * Algorithm context cache manages algorithm context values in a clustered environment. */ public class AlgorithmContextCache { - private static final Log log = LogFactory.getLog(AlgorithmContextCache.class); + @SuppressWarnings("unused") + private static final Log log = LogFactory.getLog(AlgorithmContextCache.class); // TODO Current member index should be stored in a context property. This map may grow since entris are not deleted when clusters are removed. private static Map<String, Integer> clusterServiceToMemberIndex = new HashMap<String, Integer>(); http://git-wip-us.apache.org/repos/asf/stratos/blob/dedea520/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/conf/LoadBalancerConfiguration.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/conf/LoadBalancerConfiguration.java b/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/conf/LoadBalancerConfiguration.java index 0dd8056..3c6c5d1 100644 --- a/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/conf/LoadBalancerConfiguration.java +++ b/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/conf/LoadBalancerConfiguration.java @@ -261,8 +261,6 @@ public class LoadBalancerConfiguration { private static class LoadBalancerConfigurationReader { - private String property; - public LoadBalancerConfiguration readFromFile() { String configFilePath = System.getProperty("loadbalancer.conf.file"); if (configFilePath == null) { http://git-wip-us.apache.org/repos/asf/stratos/blob/dedea520/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/context/LoadBalancerContextUtil.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/context/LoadBalancerContextUtil.java b/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/context/LoadBalancerContextUtil.java index 5761428..bfe0ddf 100644 --- a/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/context/LoadBalancerContextUtil.java +++ b/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/context/LoadBalancerContextUtil.java @@ -248,7 +248,8 @@ public class LoadBalancerContextUtil { * @param tenantId * @return */ - private static Cluster findCluster(String serviceName, int tenantId) { + @SuppressWarnings("unused") + private static Cluster findCluster(String serviceName, int tenantId) { Service service = TopologyManager.getTopology().getService(serviceName); if (service == null) { throw new RuntimeException(String.format("Service not found: %s", serviceName)); http://git-wip-us.apache.org/repos/asf/stratos/blob/dedea520/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/context/map/MemberIpHostnameMap.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/context/map/MemberIpHostnameMap.java b/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/context/map/MemberIpHostnameMap.java index 715f3ce..ef3e519 100644 --- a/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/context/map/MemberIpHostnameMap.java +++ b/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/context/map/MemberIpHostnameMap.java @@ -28,7 +28,8 @@ import java.util.concurrent.ConcurrentHashMap; * Member-ip -> hostname map for maintaining cluster hostnames of all members against their ip addresses. */ public class MemberIpHostnameMap { - private static final Log log = LogFactory.getLog(MemberIpHostnameMap.class); + @SuppressWarnings("unused") + private static final Log log = LogFactory.getLog(MemberIpHostnameMap.class); private ConcurrentHashMap<String, String> concurrentHashMap; http://git-wip-us.apache.org/repos/asf/stratos/blob/dedea520/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/endpoint/TenantAwareLoadBalanceEndpoint.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/endpoint/TenantAwareLoadBalanceEndpoint.java b/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/endpoint/TenantAwareLoadBalanceEndpoint.java index 395cd9a..0ed247f 100644 --- a/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/endpoint/TenantAwareLoadBalanceEndpoint.java +++ b/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/endpoint/TenantAwareLoadBalanceEndpoint.java @@ -863,7 +863,7 @@ public class TenantAwareLoadBalanceEndpoint extends org.apache.synapse.endpoints if (isSessionAffinityBasedLB()) { //We are sending the this message on a new session, // hence we need to remove previous session information - Set pros = synCtx.getPropertyKeySet(); + Set<?> pros = synCtx.getPropertyKeySet(); if (pros != null) { pros.remove(SynapseConstants.PROP_SAL_CURRENT_SESSION_INFORMATION); } http://git-wip-us.apache.org/repos/asf/stratos/blob/dedea520/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/statistics/InFlightRequestDecrementCallable.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/statistics/InFlightRequestDecrementCallable.java b/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/statistics/InFlightRequestDecrementCallable.java index a880d32..5fb712f 100644 --- a/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/statistics/InFlightRequestDecrementCallable.java +++ b/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/statistics/InFlightRequestDecrementCallable.java @@ -23,7 +23,7 @@ import java.util.concurrent.Callable; /** * In-flight request decrement callable definition. */ -public class InFlightRequestDecrementCallable implements Callable { +public class InFlightRequestDecrementCallable implements Callable<Object> { private String clusterId; public InFlightRequestDecrementCallable(String clusterId) { http://git-wip-us.apache.org/repos/asf/stratos/blob/dedea520/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/statistics/InFlightRequestIncrementCallable.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/statistics/InFlightRequestIncrementCallable.java b/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/statistics/InFlightRequestIncrementCallable.java index e670eab..759fa8a 100644 --- a/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/statistics/InFlightRequestIncrementCallable.java +++ b/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/statistics/InFlightRequestIncrementCallable.java @@ -23,7 +23,7 @@ import java.util.concurrent.Callable; /** * In-flight request increment callable definition. */ -public class InFlightRequestIncrementCallable implements Callable { +public class InFlightRequestIncrementCallable implements Callable<Object> { private String clusterId; public InFlightRequestIncrementCallable(String clusterId) {
