You are viewing a plain text version of this content. The canonical link for it is here.
Posted to fx-dev@ws.apache.org by ja...@apache.org on 2004/08/11 12:48:15 UTC

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

jaliya      2004/08/11 03:48:15

  Modified:    sandesha/src/org/apache/sandesha/server
                        TerminateSequenceProcessor.java
  Log:
  Message Processors implemented
  
  Revision  Changes    Path
  1.2       +15 -8     ws-fx/sandesha/src/org/apache/sandesha/server/TerminateSequenceProcessor.java
  
  Index: TerminateSequenceProcessor.java
  ===================================================================
  RCS file: /home/cvs/ws-fx/sandesha/src/org/apache/sandesha/server/TerminateSequenceProcessor.java,v
  retrieving revision 1.1
  retrieving revision 1.2
  diff -u -r1.1 -r1.2
  --- TerminateSequenceProcessor.java	4 Aug 2004 12:05:43 -0000	1.1
  +++ TerminateSequenceProcessor.java	11 Aug 2004 10:48:15 -0000	1.2
  @@ -16,24 +16,31 @@
    */
   package org.apache.sandesha.server;
   
  +import org.apache.sandesha.IStorageManager;
   import org.apache.sandesha.RMMessageContext;
  +import org.apache.sandesha.ws.rm.TerminateSequence;
   
   /**
    * @author 
    */
  -public class TerminateSequenceProcessor implements IRMMessageProcessor{
  +public class TerminateSequenceProcessor implements IRMMessageProcessor {
  +	
  +	IStorageManager storageManger=null;
  +	
  +	public TerminateSequenceProcessor(IStorageManager storageManger){
  +		this.storageManger=	storageManger;
  +	}
   
  -	/* (non-Javadoc)
  -	 * @see org.apache.sandesha.server.RMMessageProcessor#processMessage(org.apache.sandesha.RMMessageContext)
  -	 */
   	public boolean processMessage(RMMessageContext rmMessageContext) {
  -		// TODO Auto-generated method stub
  +
  +		TerminateSequence terminateSeq = rmMessageContext.getRMHeaders().getTerminateSequence();
  +		String seqID = terminateSeq.getIdentifier().getIdentifier();
  +		//TODO *****************************************************************************
  +		//storageManger.terminateSequence(String sequenceID);
   		return false;
   	}
   
  -	/* (non-Javadoc)
  -	 * @see org.apache.sandesha.server.IRMMessageProcessor#getSynchronousResponse()
  -	 */
  +	
   	public Object getSynchronousResponse() {
   		// TODO Auto-generated method stub
   		return null;