[jBoss-Dev] CVS update: spyderMQ/src/java/org/spydermqSpyQueueSession.java SpyTopicSession.java

[jBoss CVS Development]

  User: hiram   
  Date: 00/12/07 11:41:12

  Modified:    src/java/org/spydermq SpyQueueSession.java
                        SpyTopicSession.java
  Log:
  Fixed a persistence bug.
  
  Revision  Changes    Path
  1.6       +2 -2      spyderMQ/src/java/org/spydermq/SpyQueueSession.java
  
  Index: SpyQueueSession.java
  ===================================================================
  RCS file: /products/cvs/ejboss/spyderMQ/src/java/org/spydermq/SpyQueueSession.java,v
  retrieving revision 1.5
  retrieving revision 1.6
  diff -u -r1.5 -r1.6
  --- SpyQueueSession.java      2000/11/19 19:59:57     1.5
  +++ SpyQueueSession.java      2000/12/07 19:41:11     1.6
  @@ -23,7 +23,7 @@
    *      
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.5 $
  + *   @version $Revision: 1.6 $
    */
   public class SpyQueueSession 
        extends SpySession 
  @@ -108,7 +108,7 @@
                // If client is not doing persistence then we have to make sure the 
server
                // gets the persistent message before we return. (This is done in the 
commit for
                // transacted sessions.)
  -             if( !clientPersistence && transacted && 
m.getJMSDeliveryMode()==DeliveryMode.PERSISTENT) {
  +             if( !clientPersistence && !transacted && 
m.getJMSDeliveryMode()==DeliveryMode.PERSISTENT) {
                        //Wait for the sending thread to sleep
                        synchronized (mutex) {
                                mutex.waitToSleep();
  
  
  
  1.8       +3 -2      spyderMQ/src/java/org/spydermq/SpyTopicSession.java
  
  Index: SpyTopicSession.java
  ===================================================================
  RCS file: /products/cvs/ejboss/spyderMQ/src/java/org/spydermq/SpyTopicSession.java,v
  retrieving revision 1.7
  retrieving revision 1.8
  diff -u -r1.7 -r1.8
  --- SpyTopicSession.java      2000/11/19 19:59:57     1.7
  +++ SpyTopicSession.java      2000/12/07 19:41:11     1.8
  @@ -28,7 +28,7 @@
    *      
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.7 $
  + *   @version $Revision: 1.8 $
    */
   public class SpyTopicSession 
        extends SpySession 
  @@ -40,6 +40,7 @@
        SpyTopicSession(SpyConnection myConnection, boolean transacted, int 
acknowledgeMode, boolean stop)
        {
                super(myConnection,transacted,acknowledgeMode,stop);
  +             clientPersistence = false;
        }
   
        // Public --------------------------------------------------------
  @@ -119,7 +120,7 @@
                // If client is not doing persistence then we have to make sure the 
server
                // gets the persistent message before we return. (This is done in the 
commit for
                // transacted sessions.)
  -             if( !clientPersistence && transacted && 
m.getJMSDeliveryMode()==javax.jms.DeliveryMode.PERSISTENT) {
  +             if( !clientPersistence && !transacted && 
m.getJMSDeliveryMode()==javax.jms.DeliveryMode.PERSISTENT) {
                        //Wait for the sending thread to sleep
                        synchronized (mutex) {
                                mutex.waitToSleep();