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

[jBoss CVS Development]

  User: hiram   
  Date: 00/12/26 12:11:05

  Modified:    src/java/org/spydermq SpySession.java
  Log:
  Bug Fix: The sessionConsumers used by the ConnectionConsumer
  were erroniously unsubscribing themselfs from the provider.
  
  Revision  Changes    Path
  1.21      +6 -1      spyderMQ/src/java/org/spydermq/SpySession.java
  
  Index: SpySession.java
  ===================================================================
  RCS file: /products/cvs/ejboss/spyderMQ/src/java/org/spydermq/SpySession.java,v
  retrieving revision 1.20
  retrieving revision 1.21
  diff -u -r1.20 -r1.21
  --- SpySession.java   2000/12/26 04:15:50     1.20
  +++ SpySession.java   2000/12/26 20:11:04     1.21
  @@ -34,7 +34,7 @@
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    *   @author Hiram Chirino ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.20 $
  + *   @version $Revision: 1.21 $
    */
   abstract public class SpySession 
        implements Runnable, Session, XASession
  @@ -424,7 +424,12 @@
   
        void removeConsumer(SpyMessageConsumer who) throws JMSException
        {
  -
  +             // The session consumer will remove itself from the session
  +             // but no action has to be taken.  The ConnectionConsumer will
  +             // unsubscribe itself from the provider.
  +             if( who == sessionConsumer ) 
  +                     return;
  +             
                synchronized (connection) {                     
                        connection.removeConsumer( who );
                }