[Ubermq-commits] jms/src/com/ubermq/jms/client/unicast UnicastTopicConnection.java,1.9,1.10

[<ji...@us...>]

Update of /cvsroot/ubermq/jms/src/com/ubermq/jms/client/unicast
In directory usw-pr-cvs1:/tmp/cvs-serv23405/src/com/ubermq/jms/client/unicast

Modified Files:
	UnicastTopicConnection.java 
Log Message:
backoff automatic exception listener


Index: UnicastTopicConnection.java
===================================================================
RCS file: /cvsroot/ubermq/jms/src/com/ubermq/jms/client/unicast/UnicastTopicConnection.java,v
retrieving revision 1.9
retrieving revision 1.10
diff -C2 -d -r1.9 -r1.10
*** UnicastTopicConnection.java	25 Sep 2002 00:42:19 -0000	1.9
--- UnicastTopicConnection.java	25 Sep 2002 00:48:29 -0000	1.10
***************
*** 89,98 ****
  
      /**
!      * Starts a reconnect heartbeat. This method sets the exception listener
!      * to be the reconnect handler, but does it in such a way that a
!      * previously registered handler will still be called. <b>NOTE:</b>
!      * if you reset the exception listener after calling this method,
!      * the reconnection logic will not be called unless you call the
!      * listener previous registered.
       * @param keepAlivePeriod heartbeat interval, in milliseconds
       */
--- 89,97 ----
  
      /**
!      * Starts a heartbeat. The heartbeat will cause JMSIOException's
!      * to get forwarded to the exception handler if the connection goes down.
!      * In order to perform an automatic reconnection, call <br>
!      * <code>c.setExceptionListener(new ReconnectExceptionListener(c))</code>
!      * to enable the reconnect logic.
       * @param keepAlivePeriod heartbeat interval, in milliseconds
       */
***************
*** 117,131 ****
              catch(javax.jms.JMSException jmse) {}
  
-             // set the reconnect exception listener, and pass through
-             // to the previous guy
-             final javax.jms.ExceptionListener e = getExceptionListener();
-             final ReconnectExceptionListener rel = new ReconnectExceptionListener(this);
-             setExceptionListener(new javax.jms.ExceptionListener() {
-                         public void onException(javax.jms.JMSException p0)
-                         {
-                             rel.onException(p0);
-                             e.onException(p0);
-                         }
-                     });
          }
      }
--- 116,119 ----