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: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
