cvs commit: ws-fx/sandesha/src/org/apache/sandesha/ws/rm/providers RMProvider.java

[jaliya]

jaliya      2005/04/12 03:21:57

  Modified:    sandesha/src/org/apache/sandesha Constants.java
               sandesha/src/org/apache/sandesha/ws/rm/providers
                        RMProvider.java
  Log:
  Couldn't find the anonymous URI in the addressing jar. So add it to the RM 
Constants
  
  Revision  Changes    Path
  1.39      +4 -0      ws-fx/sandesha/src/org/apache/sandesha/Constants.java
  
  Index: Constants.java
  ===================================================================
  RCS file: /home/cvs/ws-fx/sandesha/src/org/apache/sandesha/Constants.java,v
  retrieving revision 1.38
  retrieving revision 1.39
  diff -u -r1.38 -r1.39
  --- Constants.java    11 Apr 2005 02:58:55 -0000      1.38
  +++ Constants.java    12 Apr 2005 10:21:57 -0000      1.39
  @@ -63,6 +63,10 @@
       public static final int SERVER = 1;
       public static final int CLIENT = 0;
   
  +    public interface WSA{
  +        public static final String NS_ADDRSSING_ANONYMOUS 
="http://schemas.xmlsoap.org/ws/2004/08/addressing/role/anonymous";;
  +    }
  +
   
       public interface WSRM {
           public static final String NS_PREFIX_RM = "wsrm";
  
  
  
  1.42      +5 -1      
ws-fx/sandesha/src/org/apache/sandesha/ws/rm/providers/RMProvider.java
  
  Index: RMProvider.java
  ===================================================================
  RCS file: 
/home/cvs/ws-fx/sandesha/src/org/apache/sandesha/ws/rm/providers/RMProvider.java,v
  retrieving revision 1.41
  retrieving revision 1.42
  diff -u -r1.41 -r1.42
  --- RMProvider.java   12 Apr 2005 02:15:33 -0000      1.41
  +++ RMProvider.java   12 Apr 2005 10:21:57 -0000      1.42
  @@ -78,6 +78,7 @@
                   FaultProcessor faultProcessor = new 
FaultProcessor(storageManager, af);
   
                   if (!faultProcessor.processMessage(rmMessageContext)) {
  +                    msgContext.setPastPivot(true);
                       msgContext.setResponseMessage(null);
                       return;
                   }
  @@ -99,9 +100,11 @@
   
               try {
                   if (!rmMessageProcessor.processMessage(rmMessageContext)) {
  +                    msgContext.setPastPivot(true);
                       msgContext.setResponseMessage(null);
                   } else {
  -                    // TODO Get the from envecreator
  +                    msgContext.setPastPivot(true);
  +                    // TODO Get the from envCreator
   
                       // SOAPEnvelope 
resEn=EnvelopeCreator.createAcknowledgementEnvelope()
                   }
  @@ -111,6 +114,7 @@
                   FaultProcessor faultProcessor = new 
FaultProcessor(storageManager, af);
   
                   if (!faultProcessor.processMessage(rmMessageContext)) {
  +                    msgContext.setPastPivot(true);
                       msgContext.setResponseMessage(null);
                       return;
                   }