Author: ruwan
Date: Mon Mar 9 09:50:28 2009
New Revision: 751638
URL: http://svn.apache.org/viewvc?rev=751638&view=rev
Log:
minor issues and refactoring
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/algorithms/RoundRobin.java
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/dispatch/SALSessions.java
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/algorithms/RoundRobin.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/algorithms/RoundRobin.java?rev=751638&r1=751637&r2=751638&view=diff
==============================================================================
---
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/algorithms/RoundRobin.java
(original)
+++
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/algorithms/RoundRobin.java
Mon Mar 9 09:50:28 2009
@@ -25,7 +25,6 @@
import org.apache.synapse.MessageContext;
import org.apache.synapse.endpoints.Endpoint;
-import java.util.ArrayList;
import java.util.List;
/**
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/dispatch/SALSessions.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/dispatch/SALSessions.java?rev=751638&r1=751637&r2=751638&view=diff
==============================================================================
---
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/dispatch/SALSessions.java
(original)
+++
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/dispatch/SALSessions.java
Mon Mar 9 09:50:28 2009
@@ -312,7 +312,7 @@
if (isClustered) {
List<String> toBeRemoved = new ArrayList<String>();
- for (Iterator props = configCtx.getPropertyNames();
props.hasNext();) {
+ for (Iterator<String> props = configCtx.getPropertyNames();
props.hasNext();) {
Object name = props.next();
if (name instanceof String && ((String)
name).startsWith(SESSION_IDS)) {
@@ -440,6 +440,7 @@
}
Map<String, Endpoint> map = childEndpoints.get(root);
+ assert endpointNames != null;
for (String endpointName : endpointNames) {
Endpoint endpoint = null;
if (map != null) {
@@ -483,6 +484,7 @@
handleException("Endpoint cannot be null.");
}
+ assert endpoint != null;
String endpointName = endpoint.getName();
if (endpointName == null && endpoint instanceof IndirectEndpoint) {
endpointName = ((IndirectEndpoint) endpoint).getKey();
@@ -519,6 +521,7 @@
}
long expireTimeWindow = -1;
+ assert endpoints != null;
for (Endpoint endpoint : endpoints) {
if (endpoint instanceof SALoadbalanceEndpoint) {
