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/10/20 12:17:00 UTC

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

jaliya      2004/10/20 03:17:00

  Modified:    sandesha/src/org/apache/sandesha IStorageManager.java
  Log:
  Two methods were added
   public void insertOutgoingMessage(RMMessageContext rmMessageContext);
   public void insertIncomingMessage(RMMessageContext rmMessageContext);
  
  Revision  Changes    Path
  1.4       +12 -2     ws-fx/sandesha/src/org/apache/sandesha/IStorageManager.java
  
  Index: IStorageManager.java
  ===================================================================
  RCS file: /home/cvs/ws-fx/sandesha/src/org/apache/sandesha/IStorageManager.java,v
  retrieving revision 1.3
  retrieving revision 1.4
  diff -u -r1.3 -r1.4
  --- IStorageManager.java	15 Sep 2004 11:33:56 -0000	1.3
  +++ IStorageManager.java	20 Oct 2004 10:17:00 -0000	1.4
  @@ -28,11 +28,13 @@
       //Here a decision need to be made whether we use the sequence already
       // created or need to
       //create a new sequence as there are no sequence request by the client.
  -    public void insertRequestMessage(RMMessageContext rmMessageContext);
  +
  +    //public void insertRequestMessage(RMMessageContext rmMessageContext);
   
       //This will be used by the Invoker but at the moment we don't need this
       // too.
  -    public void insertResponseMessage(RMMessageContext rmMessageContext);
  +
  +    //public void insertResponseMessage(RMMessageContext rmMessageContext);
   
       //This is used by the processors.
       public boolean isSequenceExist(String sequenceID);
  @@ -95,4 +97,12 @@
       //But the sequenceID is neglected.
       public long getNextMessageNumber(String sequenceID);
   
  +    //This is used by the client when storing the request messages.
  +
  +    //public void insertClientRequestMessage(RMMessageContext
  +    // rmMessageContext);
  +
  +    public void insertOutgoingMessage(RMMessageContext rmMessageContext);
  +
  +    public void insertIncomingMessage(RMMessageContext rmMessageContext);
   }