svn commit: r1199172 - in /synapse/trunk/java/modules/core/src/main/java/org/apache/synapse: config/xml/endpoints/RecipientListEndpointFactory.java config/xml/endpoints/RecipientListEndpointSerializer.java endpoints/RecipientListEndpoint.java

[uswick]

Author: uswick
Date: Tue Nov  8 10:15:45 2011
New Revision: 1199172

URL: http://svn.apache.org/viewvc?rev=1199172&view=rev
Log:
cleaning up

Modified:
    
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/endpoints/RecipientListEndpointFactory.java
    
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/endpoints/RecipientListEndpointSerializer.java
    
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/RecipientListEndpoint.java

Modified: 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/endpoints/RecipientListEndpointFactory.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/endpoints/RecipientListEndpointFactory.java?rev=1199172&r1=1199171&r2=1199172&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/endpoints/RecipientListEndpointFactory.java
 (original)
+++ 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/endpoints/RecipientListEndpointFactory.java
 Tue Nov  8 10:15:45 2011
@@ -112,10 +112,10 @@ public class RecipientListEndpointFactor
             } else if (recipientListElement.getFirstChildWithName(DYNAMIC_SET) 
!= null) {
                 OMElement dynamicSetElement = 
recipientListElement.getFirstChildWithName(DYNAMIC_SET);
                 Value dynamicEndpointSet = new 
ValueFactory().createValue("value", dynamicSetElement);
-                String maxStr = dynamicSetElement.getAttributeValue(new 
QName("max-cache"));
+                String cachedEpsStr = dynamicSetElement.getAttributeValue(new 
QName("cache"));
                 int maxCache = -1;
                 try {
-                    maxCache = Integer.parseInt(maxStr);
+                    maxCache = Integer.parseInt(cachedEpsStr);
                 } catch (NumberFormatException e) {
 
                 }

Modified: 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/endpoints/RecipientListEndpointSerializer.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/endpoints/RecipientListEndpointSerializer.java?rev=1199172&r1=1199171&r2=1199172&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/endpoints/RecipientListEndpointSerializer.java
 (original)
+++ 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/endpoints/RecipientListEndpointSerializer.java
 Tue Nov  8 10:15:45 2011
@@ -81,7 +81,7 @@ public class RecipientListEndpointSerial
             OMElement dynamicEpEle = fac.createOMElement(
                     "endpoints", SynapseConstants.SYNAPSE_OMNAMESPACE, 
recipientListElement);
             new 
ValueSerializer().serializeValue(recipientListEndpoint.getDynamicEnpointSet(), 
"value", dynamicEpEle);
-            dynamicEpEle.addAttribute(fac.createOMAttribute("max-cache", null,
+            dynamicEpEle.addAttribute(fac.createOMAttribute("cache", null,
                                                             
String.valueOf(recipientListEndpoint.getCurrentPoolSize())));
             recipientListElement.addChild(dynamicEpEle);
         }

Modified: 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/RecipientListEndpoint.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/RecipientListEndpoint.java?rev=1199172&r1=1199171&r2=1199172&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/RecipientListEndpoint.java
 (original)
+++ 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/RecipientListEndpoint.java
 Tue Nov  8 10:15:45 2011
@@ -61,7 +61,6 @@ public class RecipientListEndpoint exten
        /**
         * Should this recipient list failover;
         */
-       private boolean failover;
     private int currentPool;
 
     private SynapseEnvironment env = null;
@@ -129,15 +128,12 @@ public class RecipientListEndpoint exten
                 } catch (AxisFault e) {
                     handleException("Error cloning the message context", e);
                 }
-
                 //Used when aggregating responses
                 newCtx.setProperty(EIPConstants.MESSAGE_SEQUENCE,
                                    String.valueOf(i++) + 
EIPConstants.MESSAGE_SEQUENCE_DELEMITER +
                                    children.size());
-
                 // evaluate the endpoint properties
                 evaluateProperties(newCtx);
-
                 newCtx.pushFaultHandler(this);
                 childEndpoint.send(newCtx);
             }
@@ -311,14 +307,6 @@ public class RecipientListEndpoint exten
                this.members = members;
        }
 
-       public boolean isFailover() {
-               return failover;
-       }
-
-       public void setFailover(boolean failover) {
-               this.failover = failover;
-       }
-
     public Value getDynamicEnpointSet() {
         return dynamicEnpointSet;
     }