[JBoss-dev] CVS update: jbossmq/src/main/org/jboss/mq/pm/jdbc MessageLog.java

[JAYESH PARAYALI]

  User: jayeshpk
  Date: 01/09/04 08:05:16

  Modified:    src/main/org/jboss/mq/pm/jdbc MessageLog.java
  Log:
  Changed MessageLog constructor
  
  Revision  Changes    Path
  1.4       +10 -9     jbossmq/src/main/org/jboss/mq/pm/jdbc/MessageLog.java
  
  Index: MessageLog.java
  ===================================================================
  RCS file: /cvsroot/jboss/jbossmq/src/main/org/jboss/mq/pm/jdbc/MessageLog.java,v
  retrieving revision 1.3
  retrieving revision 1.4
  diff -u -r1.3 -r1.4
  --- MessageLog.java   2001/08/31 04:39:08     1.3
  +++ MessageLog.java   2001/09/04 15:05:16     1.4
  @@ -28,7 +28,7 @@
    * queue in case of provider failure.
    *
    * @author: Jayesh Parayali ([EMAIL PROTECTED])
  - * @version $Revision: 1.3 $
  + * @version $Revision: 1.4 $
    */
   public class MessageLog {
   
  @@ -42,7 +42,7 @@
      // Public Methods
      /////////////////////////////////////////////////////////////////////
      public void close() throws JMSException {
  -   }   
  +   }
   
      public SpyMessage[] restore(java.util.TreeSet comittingTXs, String dest) throws 
JMSException {
          String destin= dest.substring(21, dest.length());
  @@ -93,19 +93,20 @@
          for (int i= 0; iter.hasNext(); i++)
                 rc[i]= (SpyMessage) iter.next();
          return rc;
  -   }   
  +   }
   
      private void throwJMSException(String message, Exception e) throws JMSException {
          JMSException newE= new SpyJMSException(message);
          newE.setLinkedException(e);
          throw newE;
  -   }   
  +   }
   
      /////////////////////////////////////////////////////////////////////
      // Constructor
      /////////////////////////////////////////////////////////////////////
  -   public MessageLog(String dest) throws JMSException {
  -   }   
  +   public MessageLog(javax.sql.DataSource datasource, String dest) throws 
JMSException {
  +       this.datasource = datasource;
  +   }
   
      public void add(SpyMessage message, org.jboss.mq.pm.Tx transactionId) throws 
JMSException {
          PreparedStatement pstmt= null;
  @@ -146,11 +147,11 @@
                 }
   
          }
  -   }   
  +   }
   
      public javax.sql.DataSource getDatasource() {
          return datasource;
  -   }   
  +   }
   
      public void remove(SpyMessage message, org.jboss.mq.pm.Tx transactionId) throws 
JMSException {
          PreparedStatement pstmt= null;
  @@ -180,9 +181,9 @@
                 }
   
          }
  -   }   
  +   }
   
      public void setDatasource(javax.sql.DataSource newDatasource) {
          datasource= newDatasource;
  -   }   
  +   }
   }
  
  
  

_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development