modules/core/src/main/java/org/apache/savan/eventing/client/EventingClient.java - axis-axis2-java-savan - Git at Google

 /*
  * Copyright  1999-2004 The Apache Software Foundation.
  *
  *  Licensed under the Apache License, Version 2.0 (the "License");
  *  you may not use this file except in compliance with the License.
  *  You may obtain a copy of the License at
  *
  *      http://www.apache.org/licenses/LICENSE-2.0
  *
  *  Unless required by applicable law or agreed to in writing, software
  *  distributed under the License is distributed on an "AS IS" BASIS,
  *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  *  See the License for the specific language governing permissions and
  *  limitations under the License.
  *
  */

 package org.apache.savan.eventing.client;

 import org.apache.axiom.om.OMAbstractFactory;
 import org.apache.axiom.om.OMAttribute;
 import org.apache.axiom.om.OMElement;
 import org.apache.axiom.om.OMNamespace;
 import org.apache.axiom.soap.*;
 import org.apache.axis2.addressing.AddressingConstants;
 import org.apache.axis2.addressing.EndpointReference;
 import org.apache.axis2.addressing.EndpointReferenceHelper;
 import org.apache.axis2.client.Options;
 import org.apache.axis2.client.ServiceClient;
 import org.apache.axis2.databinding.types.Duration;
 import org.apache.axis2.databinding.utils.ConverterUtil;
 import org.apache.savan.eventing.EventingConstants;
 import org.apache.savan.subscription.ExpirationBean;
 import org.apache.savan.util.CommonUtil;

 import javax.xml.namespace.QName;
 import java.util.Calendar;
 import java.util.Date;
 import java.util.HashMap;

 public class EventingClient {

     ServiceClient serviceClient = null;
     HashMap subscriptionDataMap = null;

     public EventingClient(ServiceClient serviceClient) {
         this.serviceClient = serviceClient;
         subscriptionDataMap = new HashMap();
     }

     public void subscribe(EventingClientBean bean, String subscriptionID) throws Exception {

         Options options = serviceClient.getOptions();
         if (options == null) {
             options = new Options();
             serviceClient.setOptions(options);
         }

         String SOAPVersion = options.getSoapVersionURI();
         if (SOAPVersion == null)
             SOAPVersion = SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI;

         SOAPEnvelope envelope = createSubscriptionEnvelope(bean, SOAPVersion);

         String oldAction = options.getAction();
         String action = EventingConstants.Actions.Subscribe;
         options.setAction(action);
         OMElement subscriptionResponse =
                 serviceClient.sendReceive(envelope.getBody().getFirstElement());
         SubscriptionResponseData subscriptionResponseData =
                 getSubscriptionResponseData(subscriptionResponse);

         subscriptionDataMap.put(subscriptionID, subscriptionResponseData);

         options.setAction(oldAction);
     }

     public void renewSubscription(Date newExpirationTime, String subscriptionID) throws Exception {
         String expirationString = ConverterUtil.convertToString(newExpirationTime);
         renewSubscription(expirationString, subscriptionID);
     }

     public void renewSubscription(Duration duration, String subscriptionID) throws Exception {
         String expirationString = ConverterUtil.convertToString(duration);
         renewSubscription(expirationString, subscriptionID);
     }

     private void renewSubscription(String expirationString, String subscriptionID)
             throws Exception {
         SubscriptionResponseData data =
                 (SubscriptionResponseData)subscriptionDataMap.get(subscriptionID);
         EndpointReference managerEPR = data.getSubscriptionManager();
         if (managerEPR == null)
             throw new Exception("Manager EPR is not set");

         Options options = serviceClient.getOptions();
         if (options == null) {
             options = new Options();
             serviceClient.setOptions(options);
         }

         String SOAPVersion = options.getSoapVersionURI();
         if (SOAPVersion == null)
             SOAPVersion = SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI;

         SOAPEnvelope envelope = createRenewSubscriptionEnvelope(expirationString, SOAPVersion);

         String oldAction = options.getAction();
         String action = EventingConstants.Actions.Renew;
         options.setAction(action);

         EndpointReference oldTo = serviceClient.getOptions().getTo();
         options.setTo(managerEPR);

         OMElement renewResponse = serviceClient.sendReceive(envelope.getBody().getFirstElement());

         options.setAction(oldAction);
         options.setTo(oldTo);
     }

     public void unsubscribe(String subscriptionID) throws Exception {
         SubscriptionResponseData data =
                 (SubscriptionResponseData)subscriptionDataMap.get(subscriptionID);
         EndpointReference managerEPR = data.getSubscriptionManager();
         if (managerEPR == null)
             throw new Exception("Manager EPR is not set");

         Options options = serviceClient.getOptions();
         if (options == null) {
             options = new Options();
             serviceClient.setOptions(options);
         }

         String SOAPVersion = options.getSoapVersionURI();
         if (SOAPVersion == null)
             SOAPVersion = SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI;

         SOAPEnvelope envelope = createUnsubscriptionEnvelope(SOAPVersion);

         String oldAction = options.getAction();
         String action = EventingConstants.Actions.Unsubscribe;
         options.setAction(action);

         EndpointReference oldTo = serviceClient.getOptions().getTo();
         options.setTo(managerEPR);

         OMElement unsubscribeResponse =
                 serviceClient.sendReceive(envelope.getBody().getFirstElement());
         //TODO process unsubscriber response

         options.setAction(oldAction);
         options.setTo(oldTo);
     }

     public SubscriptionStatus getSubscriptionStatus(String subscriptionID) throws Exception {
         SubscriptionResponseData data =
                 (SubscriptionResponseData)subscriptionDataMap.get(subscriptionID);
         EndpointReference managerEPR = data.getSubscriptionManager();
         if (managerEPR == null)
             throw new Exception("Manager EPR is not set");

         Options options = serviceClient.getOptions();
         if (options == null) {
             options = new Options();
             serviceClient.setOptions(options);
         }

         String SOAPVersion = options.getSoapVersionURI();
         if (SOAPVersion == null)
             SOAPVersion = SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI;

         SOAPEnvelope envelope = createGetStatusEnvelope(SOAPVersion);

         String oldAction = options.getAction();
         String action = EventingConstants.Actions.GetStatus;
         options.setAction(action);

         EndpointReference oldTo = serviceClient.getOptions().getTo();
         options.setTo(managerEPR);

         OMElement getStatusResponse =
                 serviceClient.sendReceive(envelope.getBody().getFirstElement());
         SubscriptionStatus subscriptionStatus = getSubscriptionStatus(getStatusResponse);

         options.setAction(oldAction);
         options.setTo(oldTo);

         return subscriptionStatus;
     }

     private SubscriptionResponseData getSubscriptionResponseData(OMElement responseMessagePayload)
             throws Exception {
         SubscriptionResponseData data = new SubscriptionResponseData();

         OMElement subscriberManagerElement = responseMessagePayload.getFirstChildWithName(new QName(
                 EventingConstants.EVENTING_NAMESPACE,
                 EventingConstants.ElementNames.SubscriptionManager));
         EndpointReference managerEPR = EndpointReferenceHelper.fromOM(subscriberManagerElement);
         data.setSubscriptionManager(managerEPR);

         OMElement expiresElement = responseMessagePayload.getFirstChildWithName(new QName(
                 EventingConstants.EVENTING_NAMESPACE, EventingConstants.ElementNames.Expires));
         if (expiresElement != null) {
             String text = expiresElement.getText().trim();

             ExpirationBean expirationBean = new ExpirationBean();
             if (CommonUtil.isDuration(text)) {
                 expirationBean.setDuration(true);
                 Duration duration = ConverterUtil.convertToDuration(text);
                 expirationBean.setDurationValue(duration);
             } else {
                 expirationBean.setDuration(false);
                 Date date = ConverterUtil.convertToDateTime(text).getTime();
                 expirationBean.setDateValue(date);
             }

             data.setExpiration(expirationBean);
         }

         return data;
     }

     private SubscriptionStatus getSubscriptionStatus(OMElement getStatusResponseElement)
             throws Exception {
         SubscriptionStatus subscriptionStatus = new SubscriptionStatus();

         OMElement expiresElementElement = getStatusResponseElement.getFirstChildWithName(new QName(
                 EventingConstants.EVENTING_NAMESPACE, EventingConstants.ElementNames.Expires));
         if (expiresElementElement != null) {
             String valueStr = expiresElementElement.getText();
 //			long expires = Long.parseLong(valueStr);
             subscriptionStatus.setExpirationValue(valueStr);
         }

         return subscriptionStatus;
     }

     private SOAPEnvelope createSubscriptionEnvelope(EventingClientBean bean, String SOAPVersion)
             throws Exception {
         SOAPFactory factory = null;

         if (SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI.equals(SOAPVersion))
             factory = OMAbstractFactory.getSOAP11Factory();
         else if (SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI.equals(SOAPVersion))
             factory = OMAbstractFactory.getSOAP12Factory();
         else throw new Exception("Unknown SOAP version");

         SOAPEnvelope envelope = factory.getDefaultEnvelope();
         SOAPBody body = envelope.getBody();

         OMNamespace ens = factory.createOMNamespace(EventingConstants.EVENTING_NAMESPACE,
                                                     EventingConstants.EVENTING_PREFIX);

         OMElement subscriptionElement =
                 factory.createOMElement(EventingConstants.ElementNames.Subscribe, ens);

         EndpointReference endToEPR = bean.getEndToEPR();
         if (bean.getEndToEPR() != null) {
             OMElement endToElement = EndpointReferenceHelper.toOM(
                     subscriptionElement.getOMFactory(), endToEPR, new QName(
                     EventingConstants.EVENTING_NAMESPACE, EventingConstants.ElementNames.EndTo,
                     EventingConstants.EVENTING_PREFIX),
                                                                   AddressingConstants.Submission.WSA_NAMESPACE);
             subscriptionElement.addChild(endToElement);
         }

         EndpointReference deliveryEPR = bean.getDeliveryEPR();
         if (deliveryEPR == null)
             throw new Exception("Delivery EPR is not set");

         OMElement deliveryElement =
                 factory.createOMElement(EventingConstants.ElementNames.Delivery, ens);
         OMElement notifyToElement = EndpointReferenceHelper.toOM(subscriptionElement.getOMFactory(),
                                                                  deliveryEPR, new QName(
                 EventingConstants.EVENTING_NAMESPACE, EventingConstants.ElementNames.NotifyTo,
                 EventingConstants.EVENTING_PREFIX), AddressingConstants.Submission.WSA_NAMESPACE);

         deliveryElement.addChild(notifyToElement);
         subscriptionElement.addChild(deliveryElement);

         if (bean.getExpirationTime() != null || bean.getExpirationDuration() != null) {
             String timeString = null;

             //if time is set it will be taken. Otherwise duration will be taken.
             if (bean.getExpirationTime() != null) {
                 Date date = bean.getExpirationTime();
                 Calendar calendar = Calendar.getInstance();
                 calendar.setTime(date);
                 timeString = ConverterUtil.convertToString(calendar);
             } else if (bean.getExpirationDuration() != null) {
                 Duration duration = bean.getExpirationDuration();
                 timeString = ConverterUtil.convertToString(duration);
             }

             OMElement expiresElement =
                     factory.createOMElement(EventingConstants.ElementNames.Expires, ens);
             expiresElement.setText(timeString);
             subscriptionElement.addChild(expiresElement);
         }

         if (bean.getFilter() != null) {
             String filter = bean.getFilter();
             String dialect = bean.getFilterDialect();

             OMElement filterElement =
                     factory.createOMElement(EventingConstants.ElementNames.Filter, ens);
             OMAttribute dialectAttr = factory.createOMAttribute(
                     EventingConstants.ElementNames.Dialect, null, dialect);
             filterElement.addAttribute(dialectAttr);
             filterElement.setText(filter);

             subscriptionElement.addChild(filterElement);
         }

         body.addChild(subscriptionElement);

         return envelope;
     }

     private SOAPEnvelope createRenewSubscriptionEnvelope(String expiresString, String SOAPVersion)
             throws Exception {
         SOAPFactory factory = null;

         if (SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI.equals(SOAPVersion))
             factory = OMAbstractFactory.getSOAP11Factory();
         else if (SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI.equals(SOAPVersion))
             factory = OMAbstractFactory.getSOAP12Factory();
         else throw new Exception("Unknown SOAP version");

         SOAPEnvelope envelope = factory.getDefaultEnvelope();
         SOAPBody body = envelope.getBody();

         OMNamespace ens = factory.createOMNamespace(EventingConstants.EVENTING_NAMESPACE,
                                                     EventingConstants.EVENTING_PREFIX);
         OMElement renewElement = factory.createOMElement(EventingConstants.ElementNames.Renew, ens);
         OMElement expiresElement =
                 factory.createOMElement(EventingConstants.ElementNames.Expires, ens);
         expiresElement.setText(expiresString);
         renewElement.addChild(expiresElement);

         body.addChild(renewElement);

         return envelope;
     }

     private SOAPEnvelope createUnsubscriptionEnvelope(String SOAPVersion) throws Exception {
         SOAPFactory factory = null;

         if (SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI.equals(SOAPVersion))
             factory = OMAbstractFactory.getSOAP11Factory();
         else if (SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI.equals(SOAPVersion))
             factory = OMAbstractFactory.getSOAP12Factory();
         else throw new Exception("Unknown SOAP version");

         SOAPEnvelope envelope = factory.getDefaultEnvelope();
         SOAPBody body = envelope.getBody();

         OMNamespace ens = factory.createOMNamespace(EventingConstants.EVENTING_NAMESPACE,
                                                     EventingConstants.EVENTING_PREFIX);
         OMElement unsubscribeElement =
                 factory.createOMElement(EventingConstants.ElementNames.Unsubscribe, ens);
         body.addChild(unsubscribeElement);

         return envelope;
     }

     private SOAPEnvelope createGetStatusEnvelope(String SOAPVersion) throws Exception {
         SOAPFactory factory = null;

         if (SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI.equals(SOAPVersion))
             factory = OMAbstractFactory.getSOAP11Factory();
         else if (SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI.equals(SOAPVersion))
             factory = OMAbstractFactory.getSOAP12Factory();
         else throw new Exception("Unknown SOAP version");

         SOAPEnvelope envelope = factory.getDefaultEnvelope();
         SOAPBody body = envelope.getBody();

         OMNamespace ens = factory.createOMNamespace(EventingConstants.EVENTING_NAMESPACE,
                                                     EventingConstants.EVENTING_PREFIX);
         OMElement getStatusElement =
                 factory.createOMElement(EventingConstants.ElementNames.GetStatus, ens);
         body.addChild(getStatusElement);

         return envelope;
     }

 }
	/*
	* Copyright 1999-2004 The Apache Software Foundation.
	*
	* Licensed under the Apache License, Version 2.0 (the "License");
	* you may not use this file except in compliance with the License.
	* You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*
	* Unless required by applicable law or agreed to in writing, software
	* distributed under the License is distributed on an "AS IS" BASIS,
	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	* See the License for the specific language governing permissions and
	* limitations under the License.
	*
	*/

	package org.apache.savan.eventing.client;

	import org.apache.axiom.om.OMAbstractFactory;
	import org.apache.axiom.om.OMAttribute;
	import org.apache.axiom.om.OMElement;
	import org.apache.axiom.om.OMNamespace;
	import org.apache.axiom.soap.*;
	import org.apache.axis2.addressing.AddressingConstants;
	import org.apache.axis2.addressing.EndpointReference;
	import org.apache.axis2.addressing.EndpointReferenceHelper;
	import org.apache.axis2.client.Options;
	import org.apache.axis2.client.ServiceClient;
	import org.apache.axis2.databinding.types.Duration;
	import org.apache.axis2.databinding.utils.ConverterUtil;
	import org.apache.savan.eventing.EventingConstants;
	import org.apache.savan.subscription.ExpirationBean;
	import org.apache.savan.util.CommonUtil;

	import javax.xml.namespace.QName;
	import java.util.Calendar;
	import java.util.Date;
	import java.util.HashMap;

	public class EventingClient {

	ServiceClient serviceClient = null;
	HashMap subscriptionDataMap = null;

	public EventingClient(ServiceClient serviceClient) {
	this.serviceClient = serviceClient;
	subscriptionDataMap = new HashMap();
	}

	public void subscribe(EventingClientBean bean, String subscriptionID) throws Exception {

	Options options = serviceClient.getOptions();
	if (options == null) {
	options = new Options();
	serviceClient.setOptions(options);
	}

	String SOAPVersion = options.getSoapVersionURI();
	if (SOAPVersion == null)
	SOAPVersion = SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI;

	SOAPEnvelope envelope = createSubscriptionEnvelope(bean, SOAPVersion);

	String oldAction = options.getAction();
	String action = EventingConstants.Actions.Subscribe;
	options.setAction(action);
	OMElement subscriptionResponse =
	serviceClient.sendReceive(envelope.getBody().getFirstElement());
	SubscriptionResponseData subscriptionResponseData =
	getSubscriptionResponseData(subscriptionResponse);

	subscriptionDataMap.put(subscriptionID, subscriptionResponseData);

	options.setAction(oldAction);
	}

	public void renewSubscription(Date newExpirationTime, String subscriptionID) throws Exception {
	String expirationString = ConverterUtil.convertToString(newExpirationTime);
	renewSubscription(expirationString, subscriptionID);
	}

	public void renewSubscription(Duration duration, String subscriptionID) throws Exception {
	String expirationString = ConverterUtil.convertToString(duration);
	renewSubscription(expirationString, subscriptionID);
	}

	private void renewSubscription(String expirationString, String subscriptionID)
	throws Exception {
	SubscriptionResponseData data =
	(SubscriptionResponseData)subscriptionDataMap.get(subscriptionID);
	EndpointReference managerEPR = data.getSubscriptionManager();
	if (managerEPR == null)
	throw new Exception("Manager EPR is not set");

	Options options = serviceClient.getOptions();
	if (options == null) {
	options = new Options();
	serviceClient.setOptions(options);
	}

	String SOAPVersion = options.getSoapVersionURI();
	if (SOAPVersion == null)
	SOAPVersion = SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI;

	SOAPEnvelope envelope = createRenewSubscriptionEnvelope(expirationString, SOAPVersion);

	String oldAction = options.getAction();
	String action = EventingConstants.Actions.Renew;
	options.setAction(action);

	EndpointReference oldTo = serviceClient.getOptions().getTo();
	options.setTo(managerEPR);

	OMElement renewResponse = serviceClient.sendReceive(envelope.getBody().getFirstElement());

	options.setAction(oldAction);
	options.setTo(oldTo);
	}

	public void unsubscribe(String subscriptionID) throws Exception {
	SubscriptionResponseData data =
	(SubscriptionResponseData)subscriptionDataMap.get(subscriptionID);
	EndpointReference managerEPR = data.getSubscriptionManager();
	if (managerEPR == null)
	throw new Exception("Manager EPR is not set");

	Options options = serviceClient.getOptions();
	if (options == null) {
	options = new Options();
	serviceClient.setOptions(options);
	}

	String SOAPVersion = options.getSoapVersionURI();
	if (SOAPVersion == null)
	SOAPVersion = SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI;

	SOAPEnvelope envelope = createUnsubscriptionEnvelope(SOAPVersion);

	String oldAction = options.getAction();
	String action = EventingConstants.Actions.Unsubscribe;
	options.setAction(action);

	EndpointReference oldTo = serviceClient.getOptions().getTo();
	options.setTo(managerEPR);

	OMElement unsubscribeResponse =
	serviceClient.sendReceive(envelope.getBody().getFirstElement());
	//TODO process unsubscriber response

	options.setAction(oldAction);
	options.setTo(oldTo);
	}

	public SubscriptionStatus getSubscriptionStatus(String subscriptionID) throws Exception {
	SubscriptionResponseData data =
	(SubscriptionResponseData)subscriptionDataMap.get(subscriptionID);
	EndpointReference managerEPR = data.getSubscriptionManager();
	if (managerEPR == null)
	throw new Exception("Manager EPR is not set");

	Options options = serviceClient.getOptions();
	if (options == null) {
	options = new Options();
	serviceClient.setOptions(options);
	}

	String SOAPVersion = options.getSoapVersionURI();
	if (SOAPVersion == null)
	SOAPVersion = SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI;

	SOAPEnvelope envelope = createGetStatusEnvelope(SOAPVersion);

	String oldAction = options.getAction();
	String action = EventingConstants.Actions.GetStatus;
	options.setAction(action);

	EndpointReference oldTo = serviceClient.getOptions().getTo();
	options.setTo(managerEPR);

	OMElement getStatusResponse =
	serviceClient.sendReceive(envelope.getBody().getFirstElement());
	SubscriptionStatus subscriptionStatus = getSubscriptionStatus(getStatusResponse);

	options.setAction(oldAction);
	options.setTo(oldTo);

	return subscriptionStatus;
	}

	private SubscriptionResponseData getSubscriptionResponseData(OMElement responseMessagePayload)
	throws Exception {
	SubscriptionResponseData data = new SubscriptionResponseData();

	OMElement subscriberManagerElement = responseMessagePayload.getFirstChildWithName(new QName(
	EventingConstants.EVENTING_NAMESPACE,
	EventingConstants.ElementNames.SubscriptionManager));
	EndpointReference managerEPR = EndpointReferenceHelper.fromOM(subscriberManagerElement);
	data.setSubscriptionManager(managerEPR);

	OMElement expiresElement = responseMessagePayload.getFirstChildWithName(new QName(
	EventingConstants.EVENTING_NAMESPACE, EventingConstants.ElementNames.Expires));
	if (expiresElement != null) {
	String text = expiresElement.getText().trim();

	ExpirationBean expirationBean = new ExpirationBean();
	if (CommonUtil.isDuration(text)) {
	expirationBean.setDuration(true);
	Duration duration = ConverterUtil.convertToDuration(text);
	expirationBean.setDurationValue(duration);
	} else {
	expirationBean.setDuration(false);
	Date date = ConverterUtil.convertToDateTime(text).getTime();
	expirationBean.setDateValue(date);
	}

	data.setExpiration(expirationBean);
	}

	return data;
	}

	private SubscriptionStatus getSubscriptionStatus(OMElement getStatusResponseElement)
	throws Exception {
	SubscriptionStatus subscriptionStatus = new SubscriptionStatus();

	OMElement expiresElementElement = getStatusResponseElement.getFirstChildWithName(new QName(
	EventingConstants.EVENTING_NAMESPACE, EventingConstants.ElementNames.Expires));
	if (expiresElementElement != null) {
	String valueStr = expiresElementElement.getText();
	// long expires = Long.parseLong(valueStr);
	subscriptionStatus.setExpirationValue(valueStr);
	}

	return subscriptionStatus;
	}

	private SOAPEnvelope createSubscriptionEnvelope(EventingClientBean bean, String SOAPVersion)
	throws Exception {
	SOAPFactory factory = null;

	if (SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI.equals(SOAPVersion))
	factory = OMAbstractFactory.getSOAP11Factory();
	else if (SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI.equals(SOAPVersion))
	factory = OMAbstractFactory.getSOAP12Factory();
	else throw new Exception("Unknown SOAP version");

	SOAPEnvelope envelope = factory.getDefaultEnvelope();
	SOAPBody body = envelope.getBody();

	OMNamespace ens = factory.createOMNamespace(EventingConstants.EVENTING_NAMESPACE,
	EventingConstants.EVENTING_PREFIX);

	OMElement subscriptionElement =
	factory.createOMElement(EventingConstants.ElementNames.Subscribe, ens);

	EndpointReference endToEPR = bean.getEndToEPR();
	if (bean.getEndToEPR() != null) {
	OMElement endToElement = EndpointReferenceHelper.toOM(
	subscriptionElement.getOMFactory(), endToEPR, new QName(
	EventingConstants.EVENTING_NAMESPACE, EventingConstants.ElementNames.EndTo,
	EventingConstants.EVENTING_PREFIX),
	AddressingConstants.Submission.WSA_NAMESPACE);
	subscriptionElement.addChild(endToElement);
	}

	EndpointReference deliveryEPR = bean.getDeliveryEPR();
	if (deliveryEPR == null)
	throw new Exception("Delivery EPR is not set");

	OMElement deliveryElement =
	factory.createOMElement(EventingConstants.ElementNames.Delivery, ens);
	OMElement notifyToElement = EndpointReferenceHelper.toOM(subscriptionElement.getOMFactory(),
	deliveryEPR, new QName(
	EventingConstants.EVENTING_NAMESPACE, EventingConstants.ElementNames.NotifyTo,
	EventingConstants.EVENTING_PREFIX), AddressingConstants.Submission.WSA_NAMESPACE);

	deliveryElement.addChild(notifyToElement);
	subscriptionElement.addChild(deliveryElement);

	if (bean.getExpirationTime() != null \|\| bean.getExpirationDuration() != null) {
	String timeString = null;

	//if time is set it will be taken. Otherwise duration will be taken.
	if (bean.getExpirationTime() != null) {
	Date date = bean.getExpirationTime();
	Calendar calendar = Calendar.getInstance();
	calendar.setTime(date);
	timeString = ConverterUtil.convertToString(calendar);
	} else if (bean.getExpirationDuration() != null) {
	Duration duration = bean.getExpirationDuration();
	timeString = ConverterUtil.convertToString(duration);
	}

	OMElement expiresElement =
	factory.createOMElement(EventingConstants.ElementNames.Expires, ens);
	expiresElement.setText(timeString);
	subscriptionElement.addChild(expiresElement);
	}

	if (bean.getFilter() != null) {
	String filter = bean.getFilter();
	String dialect = bean.getFilterDialect();

	OMElement filterElement =
	factory.createOMElement(EventingConstants.ElementNames.Filter, ens);
	OMAttribute dialectAttr = factory.createOMAttribute(
	EventingConstants.ElementNames.Dialect, null, dialect);
	filterElement.addAttribute(dialectAttr);
	filterElement.setText(filter);

	subscriptionElement.addChild(filterElement);
	}

	body.addChild(subscriptionElement);

	return envelope;
	}

	private SOAPEnvelope createRenewSubscriptionEnvelope(String expiresString, String SOAPVersion)
	throws Exception {
	SOAPFactory factory = null;

	if (SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI.equals(SOAPVersion))
	factory = OMAbstractFactory.getSOAP11Factory();
	else if (SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI.equals(SOAPVersion))
	factory = OMAbstractFactory.getSOAP12Factory();
	else throw new Exception("Unknown SOAP version");

	SOAPEnvelope envelope = factory.getDefaultEnvelope();
	SOAPBody body = envelope.getBody();

	OMNamespace ens = factory.createOMNamespace(EventingConstants.EVENTING_NAMESPACE,
	EventingConstants.EVENTING_PREFIX);
	OMElement renewElement = factory.createOMElement(EventingConstants.ElementNames.Renew, ens);
	OMElement expiresElement =
	factory.createOMElement(EventingConstants.ElementNames.Expires, ens);
	expiresElement.setText(expiresString);
	renewElement.addChild(expiresElement);

	body.addChild(renewElement);

	return envelope;
	}

	private SOAPEnvelope createUnsubscriptionEnvelope(String SOAPVersion) throws Exception {
	SOAPFactory factory = null;

	if (SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI.equals(SOAPVersion))
	factory = OMAbstractFactory.getSOAP11Factory();
	else if (SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI.equals(SOAPVersion))
	factory = OMAbstractFactory.getSOAP12Factory();
	else throw new Exception("Unknown SOAP version");

	SOAPEnvelope envelope = factory.getDefaultEnvelope();
	SOAPBody body = envelope.getBody();

	OMNamespace ens = factory.createOMNamespace(EventingConstants.EVENTING_NAMESPACE,
	EventingConstants.EVENTING_PREFIX);
	OMElement unsubscribeElement =
	factory.createOMElement(EventingConstants.ElementNames.Unsubscribe, ens);
	body.addChild(unsubscribeElement);

	return envelope;
	}

	private SOAPEnvelope createGetStatusEnvelope(String SOAPVersion) throws Exception {
	SOAPFactory factory = null;

	if (SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI.equals(SOAPVersion))
	factory = OMAbstractFactory.getSOAP11Factory();
	else if (SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI.equals(SOAPVersion))
	factory = OMAbstractFactory.getSOAP12Factory();
	else throw new Exception("Unknown SOAP version");

	SOAPEnvelope envelope = factory.getDefaultEnvelope();
	SOAPBody body = envelope.getBody();

	OMNamespace ens = factory.createOMNamespace(EventingConstants.EVENTING_NAMESPACE,
	EventingConstants.EVENTING_PREFIX);
	OMElement getStatusElement =
	factory.createOMElement(EventingConstants.ElementNames.GetStatus, ens);
	body.addChild(getStatusElement);

	return envelope;
	}

	}