Author: chamikara
Date: Tue Oct 24 20:46:21 2006
New Revision: 467551
URL: http://svn.apache.org/viewvc?view=rev&rev=467551
Log:
Hd forgotten to add the Endpoint class :(
Added:
webservices/sandesha/trunk/java/src/org/apache/sandesha2/wsrm/Endpoint.java
(with props)
Added:
webservices/sandesha/trunk/java/src/org/apache/sandesha2/wsrm/Endpoint.java
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/wsrm/Endpoint.java?view=auto&rev=467551
==============================================================================
--- webservices/sandesha/trunk/java/src/org/apache/sandesha2/wsrm/Endpoint.java
(added)
+++ webservices/sandesha/trunk/java/src/org/apache/sandesha2/wsrm/Endpoint.java
Tue Oct 24 20:46:21 2006
@@ -0,0 +1,91 @@
+package org.apache.sandesha2.wsrm;
+
+import javax.xml.namespace.QName;
+
+import org.apache.axiom.om.OMElement;
+import org.apache.axiom.om.OMException;
+import org.apache.axiom.om.OMFactory;
+import org.apache.axis2.AxisFault;
+import org.apache.axis2.addressing.AddressingConstants;
+import org.apache.axis2.addressing.EndpointReference;
+import org.apache.axis2.addressing.EndpointReferenceHelper;
+import org.apache.sandesha2.Sandesha2Constants;
+import org.apache.sandesha2.SandeshaException;
+import org.apache.sandesha2.i18n.SandeshaMessageHelper;
+import org.apache.sandesha2.i18n.SandeshaMessageKeys;
+
+public class Endpoint implements IOMRMElement {
+
+ private EndpointReference epr;
+
+ private String rmNamespaceValue = null;
+
+ private String addressingNamespaceValue = null;
+
+ public Endpoint (String rmNamespaceValue,String
addressingNamespaceValue) throws AxisFault {
+ if (!isNamespaceSupported(rmNamespaceValue))
+ throw new SandeshaException
(SandeshaMessageHelper.getMessage(
+ SandeshaMessageKeys.unknownSpec,
+ rmNamespaceValue));
+
+ this.rmNamespaceValue = rmNamespaceValue;
+ this.addressingNamespaceValue = addressingNamespaceValue;
+ }
+
+ public Endpoint (EndpointReference epr, String rmNamespaceValue, String
addressingNamespaceValue) throws AxisFault {
+ this (rmNamespaceValue,addressingNamespaceValue);
+ this.epr = epr;
+ }
+
+ public String getNamespaceValue(){
+ return rmNamespaceValue;
+ }
+
+ public Object fromOMElement(OMElement endpointElement) throws
OMException,AxisFault {
+
+ epr = EndpointReferenceHelper.fromOM (endpointElement);
+ if (epr==null) {
+ String message = SandeshaMessageHelper.getMessage(
+
SandeshaMessageKeys.invalidElementFoundWithinElement,
+ "EPR",
+
Sandesha2Constants.WSRM_COMMON.ENDPOINT);
+ throw new SandeshaException (message);
+ }
+
+ return this;
+ }
+
+ public OMElement toOMElement(OMElement element) throws
OMException,AxisFault {
+
+ if (epr == null)
+ throw new OMException(SandeshaMessageHelper.getMessage(
+ SandeshaMessageKeys.cannotSetEndpoint,
+ null));
+
+ OMFactory factory = element.getOMFactory();
+
+ QName endpoint = new QName
(rmNamespaceValue,Sandesha2Constants.WSRM_COMMON.ENDPOINT,
Sandesha2Constants.WSRM_COMMON.NS_PREFIX_RM);
+ OMElement endpointElement = EndpointReferenceHelper.toOM
(factory,epr, endpoint,addressingNamespaceValue);
+
+ element.addChild(endpointElement);
+ return element;
+ }
+
+ public EndpointReference getEPR() {
+ return epr;
+ }
+
+ public void setEPR(EndpointReference epr) {
+ this.epr = epr;
+ }
+
+ public boolean isNamespaceSupported (String namespaceName) {
+ if
(Sandesha2Constants.SPEC_2005_02.NS_URI.equals(namespaceName))
+ return true;
+
+ if
(Sandesha2Constants.SPEC_2006_08.NS_URI.equals(namespaceName))
+ return true;
+
+ return false;
+ }
+}
Propchange:
webservices/sandesha/trunk/java/src/org/apache/sandesha2/wsrm/Endpoint.java
------------------------------------------------------------------------------
svn:executable = *
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
