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/05 13:36:36 UTC
cvs commit: ws-fx/sandesha/src/org/apache/sandesha/server RMMessageProcessorIdentifier.java
jaliya 2004/08/05 04:36:36
Modified: sandesha/src/org/apache/sandesha/server
RMMessageProcessorIdentifier.java
Log:
Implemented the method getMessageProcessor()
Revision Changes Path
1.2 +22 -4 ws-fx/sandesha/src/org/apache/sandesha/server/RMMessageProcessorIdentifier.java
Index: RMMessageProcessorIdentifier.java
===================================================================
RCS file: /home/cvs/ws-fx/sandesha/src/org/apache/sandesha/server/RMMessageProcessorIdentifier.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- RMMessageProcessorIdentifier.java 4 Aug 2004 12:05:43 -0000 1.1
+++ RMMessageProcessorIdentifier.java 5 Aug 2004 11:36:36 -0000 1.2
@@ -16,7 +16,11 @@
*/
package org.apache.sandesha.server;
-import javax.xml.soap.SOAPEnvelope;
+import org.apache.axis.message.addressing.AddressingHeaders;
+import org.apache.sandesha.RMMessageContext;
+
+import org.apache.sandesha.Constants;
+import org.apache.sandesha.ws.rm.RMHeaders;
/**
* @author
@@ -24,7 +28,21 @@
*/
public class RMMessageProcessorIdentifier {
-public IRMMessageProcessor getMessageProcessor(SOAPEnvelope soapEnv){
- return null;
-}
+ public IRMMessageProcessor getMessageProcessor(RMMessageContext rmMessageContext) {
+
+ AddressingHeaders addrHeaders = rmMessageContext.getAddressingHeaders();
+ RMHeaders rmHeaders = rmMessageContext.getRMHeaders();
+
+ if (addrHeaders.getAction().toString().equals(Constants.ACTION_CREATE_SEQUENCE)) {
+ return new CreateSequenceProcessor();
+ } else if (
+ addrHeaders.getAction().toString().equals(Constants.ACTION_CREATE_SEQUENCE_RESPONSE)) {
+ return new CreateSequenceResponseProcessor();
+ } else if (
+ addrHeaders.getAction().toString().equals(Constants.ACTION_TERMINATE_SEQUENCE)) {
+ return new TerminateSequenceProcessor();
+ } else {
+ return new CompositeProcessor();
+ }
+ }
}