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

[jBoss CVS Development]

  User: sylvain 
  Date: 00/05/23 19:56:41

  Modified:    src/java/org/spyderMQ SpyQueueReceiver.java
                        SpyQueueSession.java
  Log:
  fixed to build
  
  Revision  Changes    Path
  1.2       +4 -4      spyderMQ/src/java/org/spyderMQ/SpyQueueReceiver.java
  
  Index: SpyQueueReceiver.java
  ===================================================================
  RCS file: /products/cvs/ejboss/spyderMQ/src/java/org/spyderMQ/SpyQueueReceiver.java,v
  retrieving revision 1.1
  retrieving revision 1.2
  diff -u -r1.1 -r1.2
  --- SpyQueueReceiver.java     2000/05/24 02:52:16     1.1
  +++ SpyQueueReceiver.java     2000/05/24 02:56:41     1.2
  @@ -17,7 +17,7 @@
    *      
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.1 $
  + *   @version $Revision: 1.2 $
    */
   public class SpyQueueReceiver 
        extends SpyMessageConsumer 
  @@ -34,7 +34,7 @@
           
       SpyQueueReceiver(SpyQueueSession s,SessionQueue sq,Queue q,boolean stop) 
        {
  -             super(s,sq);
  +             super(s);
                queue=q;
                modeStop=stop;
        }
  @@ -93,11 +93,11 @@
        {       
                if (closed) throw new IllegalStateException("The MessageConsumer is 
closed");                   
                
  -             if (listener==null) {
  +/*           if (listener==null) {
                        mySessionQueue.notifyReceiverStopped(false);
                } else {
                        mySessionQueue.notifyReceiverStopped(true);
  -             }
  +             }*/
   
                messageListener=listener;
                
  
  
  
  1.7       +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.6
  retrieving revision 1.7
  diff -u -r1.6 -r1.7
  --- SpyQueueSession.java      2000/05/22 17:32:04     1.6
  +++ SpyQueueSession.java      2000/05/24 02:56:41     1.7
  @@ -23,7 +23,7 @@
    *      
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.6 $
  + *   @version $Revision: 1.7 $
    */
   public class SpyQueueSession 
        extends SpySession 
  @@ -66,7 +66,7 @@
        {
                if (closed) throw new IllegalStateException("The session is closed");  
         
                                                                                
  -             SpyQueueReceiver receiver=new SpyQueueReceiver(this,queue,modeStop);
  +             SpyQueueReceiver receiver=new 
SpyQueueReceiver(this,null,queue,modeStop);
                return receiver;
        }