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

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

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

Modified Files:
	UnicastTopicConnection.java 
Log Message:
bug fixes


Index: UnicastTopicConnection.java
===================================================================
RCS file: /cvsroot/ubermq/jms/src/com/ubermq/jms/client/unicast/UnicastTopicConnection.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -C2 -d -r1.1 -r1.2
*** UnicastTopicConnection.java	28 Aug 2002 20:47:49 -0000	1.1
--- UnicastTopicConnection.java	30 Aug 2002 15:32:51 -0000	1.2
***************
*** 2,6 ****
  import com.ubermq.jms.client.impl.*;
  
! import EDU.oswego.cs.dl.util.concurrent.ClockDaemon;
  import com.ubermq.jms.client.ClientConfig;
  import com.ubermq.jms.client.IClientSession;
--- 2,6 ----
  import com.ubermq.jms.client.impl.*;
  
! import EDU.oswego.cs.dl.util.concurrent.*;
  import com.ubermq.jms.client.ClientConfig;
  import com.ubermq.jms.client.IClientSession;
***************
*** 14,17 ****
--- 14,18 ----
  {
      private static IClientSession theSession;
+     private static ClockDaemon cd;
      
      private static final String keepAliveTopic = Configurator.getProperty(ClientConfig.UNICAST_KEEP_ALIVE,
***************
*** 21,31 ****
                                                   "30000")).intValue();
      
!     private static TopicSession keepAliveSession;
!     private static javax.jms.TopicPublisher keepAlivePublisher;
!     private static ClockDaemon cd = new ClockDaemon();
      
      static {
          try
          {
              theSession = new ClientSession();
          }
--- 22,43 ----
                                                   "30000")).intValue();
      
! 
!     // instance variables for heartbeating
!     private TopicSession keepAliveSession;
!     private javax.jms.TopicPublisher keepAlivePublisher;
      
      static {
          try
          {
+ 	    cd = new ClockDaemon();
+ 	    cd.setThreadFactory(new ThreadFactory() {
+ 		    public Thread newThread(Runnable r) {
+ 			    Thread t = new Thread(r);
+ 			    t.setDaemon(true);
+ 			    return t;
+ 		    }
+ 		   
+ 	    });
+ 
              theSession = new ClientSession();
          }