cvs commit: ws-fx/sandesha/src/org/apache/sandesha EnvelopeCreator.java

[ja...@apache.org]

jaliya      2004/08/05 23:39:21

  Added:       sandesha/src/org/apache/sandesha EnvelopeCreator.java
  Log:
  Class to create SOAPEnvelops for different requests
  
  Revision  Changes    Path
  1.1                  ws-fx/sandesha/src/org/apache/sandesha/EnvelopeCreator.java
  
  Index: EnvelopeCreator.java
  ===================================================================
  /*
   * 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.sandesha;
  
  import javax.xml.namespace.QName;
  import javax.xml.soap.SOAPException;
  import javax.xml.soap.SOAPHeaderElement;
  
  import org.apache.axis.components.uuid.UUIDGen;
  import org.apache.axis.components.uuid.UUIDGenFactory;
  import org.apache.axis.message.SOAPEnvelope;
  import org.apache.axis.message.addressing.Action;
  import org.apache.axis.message.addressing.Address;
  import org.apache.axis.message.addressing.AddressingHeaders;
  import org.apache.axis.message.addressing.From;
  import org.apache.axis.message.addressing.MessageID;
  import org.apache.axis.message.addressing.ReplyTo;
  import org.apache.axis.message.addressing.To;
  import org.apache.axis.types.URI;
  import org.apache.axis.types.URI.MalformedURIException;
  import org.apache.sandesha.ws.rm.CreateSequenceResponse;
  import org.apache.sandesha.ws.utility.Identifier;
  
  /**
   * @author JEkanayake
   *
   */
  public class EnvelopeCreator {
  	public static SOAPEnvelope createCreateSequenceResponseEnvelope(
  		String uuid,
  		RMMessageContext rmMessageContext) {
  
  		//Set the SOAPEnvelope to the resEnv of the rmMessageContext.
  
  		AddressingHeaders addressingHeaders =
  			rmMessageContext.getAddressingHeaders();
  		
  		SOAPEnvelope envelope = createBasicEnvelop();
  
  		try {
  			Action action =
  				new Action(new URI(Constants.ACTION_CREATE_SEQUENCE_RESPONSE));
  			
  			SOAPHeaderElement actionElement=action.toSOAPHeaderElement(envelope);
  			actionElement.setActor(null);
  			//??Do we need this.
  			actionElement.setMustUnderstand(true);
  			
  			//Set the messageID
  			UUIDGen uuidGen = UUIDGenFactory.getUUIDGen();
  			MessageID messageId =
  				new MessageID(new URI("uuid:" + uuidGen.nextUUID()));
  			messageId.toSOAPHeaderElement(envelope);
  
  			//Set the <wsa:From> address from the incoming <wsa:To>
  			To incommingTo = addressingHeaders.getTo();
  			URI fromAddressURI = new URI(incommingTo.toString());
  
  			Address fromAddress = new Address(fromAddressURI);
  			From from = new From(fromAddress);
  			from.toSOAPHeaderElement(envelope);
  			
  			/*We don't need <ReplyTo> when we send createSequenceResponse
  
  			ReplyTo incommingReplyTo = (ReplyTo) addressingHeaders.getReplyTo();
  			Address incommingAddress = incommingReplyTo.getAddress();
  			To to = new To(new URI(incommingAddress.toString()));
  			to.toSOAPHeaderElement(envelope);
  			
  			*/
  
  			//Need to check this for the usage of
  			MessageID incommingMessageId = addressingHeaders.getMessageID();
  			AddressingHeaders outgoingAddressingHaders =
  				new AddressingHeaders();
  			outgoingAddressingHaders.setSetMustUnderstand(true);
  			outgoingAddressingHaders.addRelatesTo(
  				incommingMessageId.toString(),
  				(new QName(Constants.WSA_PREFIX, Constants.WSA_NS)));
  			outgoingAddressingHaders.toEnvelope(envelope);
  
  			//now set the body elements
  			CreateSequenceResponse response = new CreateSequenceResponse();
  			Identifier id = new Identifier();
  			id.setIdentifier("uuid:" + uuid);
  			response.setIdentifier(id);
  			response.toSoapEnvelop(envelope);
  
  			
  			
  		} catch (MalformedURIException e) {
  			// TODO Auto-generated catch block
  			e.printStackTrace();
  		} catch (Exception e) {
  			// TODO Auto-generated catch block
  			e.printStackTrace();
  		}
  		
  		System.out.println(envelope.toString());
  		
  		return envelope;
  
  	}
  
  	public static SOAPEnvelope createBasicEnvelop() {
  
  		SOAPEnvelope soapEnv = new SOAPEnvelope();
  		addNamespaceDeclarations(soapEnv);
  
  		return soapEnv;
  
  	}
  
  	public static void addNamespaceDeclarations(SOAPEnvelope soapEnv) {
  		try {
  			soapEnv.addNamespaceDeclaration("wsrm", Constants.NS_URI_RM);
  			soapEnv.addNamespaceDeclaration(
  				"wsa",
  				org.apache.axis.message.addressing.Constants.NS_URI_ADDRESSING);
  			soapEnv.addNamespaceDeclaration("wsu", Constants.NS_URI_WSU);
  
  		} catch (SOAPException e) {
  			// TODO Auto-generated catch block
  			e.printStackTrace();
  		}
  
  	}
  
  }