You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@synapse.apache.org by us...@apache.org on 2011/11/08 11:15:45 UTC
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
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;
}