openjms-cvs

[<tan...@us...>]

Update of /cvsroot/openjms/openjms/src/main/org/exolab/jms/client
In directory sc8-pr-cvs1:/tmp/cvs-serv24568/src/main/org/exolab/jms/client

Modified Files:
	JmsQueueReceiver.java 
Log Message:
fixed NPE if consumer closed twice

Index: JmsQueueReceiver.java
===================================================================
RCS file: /cvsroot/openjms/openjms/src/main/org/exolab/jms/client/JmsQueueReceiver.java,v
retrieving revision 1.8
retrieving revision 1.9
diff -C2 -d -r1.8 -r1.9
*** JmsQueueReceiver.java	12 Oct 2001 07:55:31 -0000	1.8
--- JmsQueueReceiver.java	21 Jan 2003 14:25:59 -0000	1.9
***************
*** 112,122 ****
      
      // overwrites of JmsMessageConsumer.close
!     public void close() 
!         throws JMSException
!     {
!         // unregister this receiver from the session before closing, and then
!         // call the base class method.
!         ((JmsQueueSession)_session).removeReceiver(this);
!         super.close();
      }
  
--- 112,122 ----
      
      // overwrites of JmsMessageConsumer.close
!     public void close() throws JMSException {
!         if (_session != null) {
!             // unregister this receiver from the session before closing, and 
!             // then call the base class method.
!             ((JmsQueueSession)_session).removeReceiver(this);
!             super.close();
!         }
      }