You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@synapse.apache.org by ch...@apache.org on 2007/04/16 15:48:23 UTC
svn commit: r529245 - in
/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/endpoints:
AddressEndpointSerializer.java WSDLEndpointFactory.java
WSDLEndpointSerializer.java
Author: chathura_ce
Date: Mon Apr 16 06:48:22 2007
New Revision: 529245
URL: http://svn.apache.org/viewvc?view=rev&rev=529245
Log:
Added the timeout configuration parsing to WSDLEndpoint factory and serializer.
Modified:
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/endpoints/AddressEndpointSerializer.java
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/endpoints/WSDLEndpointFactory.java
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/endpoints/WSDLEndpointSerializer.java
Modified: webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/endpoints/AddressEndpointSerializer.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/endpoints/AddressEndpointSerializer.java?view=diff&rev=529245&r1=529244&r2=529245
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/endpoints/AddressEndpointSerializer.java (original)
+++ webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/endpoints/AddressEndpointSerializer.java Mon Apr 16 06:48:22 2007
@@ -158,6 +158,7 @@
if (endpt.getTimeoutAction() != Constants.NONE) {
OMElement timeout = fac.createOMElement("timeout", Constants.SYNAPSE_OMNAMESPACE);
+ address.addChild(timeout);
OMElement duration = fac.createOMElement("duration", Constants.SYNAPSE_OMNAMESPACE);
duration.setText(Long.toString(endpt.getTimeoutDuration()));
@@ -169,6 +170,7 @@
} else if (endpt.getTimeoutAction() == Constants.DISCARD_AND_FAULT) {
action.setText("fault");
}
+ timeout.addChild(action);
}
return address;
Modified: webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/endpoints/WSDLEndpointFactory.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/endpoints/WSDLEndpointFactory.java?view=diff&rev=529245&r1=529244&r2=529245
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/endpoints/WSDLEndpointFactory.java (original)
+++ webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/endpoints/WSDLEndpointFactory.java Mon Apr 16 06:48:22 2007
@@ -252,5 +252,32 @@
endpointDefinition.setWsRMPolicyKey(policy.getAttributeValue());
}
}
+
+ // set the timeout configuration
+ OMElement timeout = wsdlElement.getFirstChildWithName(new QName(
+ org.apache.synapse.config.xml.Constants.SYNAPSE_NAMESPACE, "timeout"));
+ if (timeout != null) {
+ OMElement duration = timeout.getFirstChildWithName(new QName(
+ org.apache.synapse.config.xml.Constants.SYNAPSE_NAMESPACE, "duration"));
+ if (duration != null) {
+ String d = duration.getText();
+ if (d != null) {
+ endpointDefinition.setTimeoutDuration(new Long(d).longValue());
+ }
+ }
+
+ OMElement action = timeout.getFirstChildWithName(new QName(
+ org.apache.synapse.config.xml.Constants.SYNAPSE_NAMESPACE, "action"));
+ if (action != null) {
+ String a = action.getText();
+ if (a != null) {
+ if (a.equalsIgnoreCase("discard")) {
+ endpointDefinition.setTimeoutAction(Constants.DISCARD);
+ } else if (a.equalsIgnoreCase("fault")) {
+ endpointDefinition.setTimeoutAction(Constants.DISCARD_AND_FAULT);
+ }
+ }
+ }
+ }
}
}
Modified: webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/endpoints/WSDLEndpointSerializer.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/endpoints/WSDLEndpointSerializer.java?view=diff&rev=529245&r1=529244&r2=529245
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/endpoints/WSDLEndpointSerializer.java (original)
+++ webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/endpoints/WSDLEndpointSerializer.java Mon Apr 16 06:48:22 2007
@@ -148,6 +148,23 @@
}
wsdlElement.addChild(sec);
}
+
+ if (endpointDefinition.getTimeoutAction() != Constants.NONE) {
+ OMElement timeout = fac.createOMElement("timeout", Constants.SYNAPSE_OMNAMESPACE);
+ wsdlElement.addChild(timeout);
+
+ OMElement duration = fac.createOMElement("duration", Constants.SYNAPSE_OMNAMESPACE);
+ duration.setText(Long.toString(endpointDefinition.getTimeoutDuration()));
+ timeout.addChild(duration);
+
+ OMElement action = fac.createOMElement("action", Constants.SYNAPSE_OMNAMESPACE);
+ if (endpointDefinition.getTimeoutAction() == Constants.DISCARD) {
+ action.setText("discard");
+ } else if (endpointDefinition.getTimeoutAction() == Constants.DISCARD_AND_FAULT) {
+ action.setText("fault");
+ }
+ timeout.addChild(action);
+ }
}
private static void handleException(String msg) {
---------------------------------------------------------------------
To unsubscribe, e-mail: synapse-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: synapse-dev-help@ws.apache.org