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;