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

[chamikara]

chamikara    2005/02/16 03:36:07

  Modified:    sandesha/src/org/apache/sandesha/ws/rm/providers
                        RMProvider.java
  Log:
  some minor changes.
  
  Revision  Changes    Path
  1.30      +11 -2     
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.29
  retrieving revision 1.30
  diff -u -r1.29 -r1.30
  --- RMProvider.java   16 Feb 2005 04:21:21 -0000      1.29
  +++ RMProvider.java   16 Feb 2005 11:36:07 -0000      1.30
  @@ -32,6 +32,7 @@
   import org.apache.sandesha.server.msgprocessors.FaultProcessor;
   import org.apache.sandesha.server.msgprocessors.IRMMessageProcessor;
   import org.apache.sandesha.storage.dao.SandeshaQueueDAO;
  +import org.apache.sandesha.storage.queue.SandeshaQueue;
   import org.apache.sandesha.ws.rm.RMHeaders;
   
   /**
  @@ -56,6 +57,7 @@
           System.out.println("RMProvider Received a SOAP REQUEST.....\n");
           RMProvider.log.info("RMProvider Received a SOAP REQUEST");
   
  +
           IStorageManager storageManager = RMInitiator.init(client);
           storageManager.init();
   
  @@ -63,8 +65,9 @@
           rmMessageContext.setMsgContext(msgContext);
           try {
               MessageValidator.validate(rmMessageContext,client);
  -        } catch (AxisFault af) {
  -            FaultProcessor faultProcessor = new 
FaultProcessor(storageManager, af);
  +        } catch (AxisFault af) { 
  +             FaultProcessor faultProcessor = new 
FaultProcessor(storageManager, af);
  +           
               if (!faultProcessor.processMessage(rmMessageContext)) {
                   msgContext.setResponseMessage(null);
                   return;
  @@ -72,6 +75,7 @@
               return;
           }
   
  +
           RMHeaders rmHeaders = rmMessageContext.getRMHeaders();
           AddressingHeaders addrHeaders = 
rmMessageContext.getAddressingHeaders();
   
  @@ -85,6 +89,7 @@
           rmMessageContext.setMessageID(addrHeaders.getMessageID().toString());
          
           IRMMessageProcessor rmMessageProcessor = 
RMMessageProcessorIdentifier.getMessageProcessor(rmMessageContext, 
storageManager);
  +
           try {
               if (!rmMessageProcessor.processMessage(rmMessageContext)) {
                   msgContext.setResponseMessage(null);
  @@ -93,6 +98,10 @@
               rmEx.printStackTrace();
               RMProvider.log.error(rmEx);
           }
  +        
  +        SandeshaQueue sq = SandeshaQueue.getInstance();
  +        sq.displayIncomingMap();
  +        sq.displayOutgoingMap();
       }
   
       //This is used by the Client to set the