[Ubermq-commits] jms/src/com/ubermq/jms/server/cluster ClusterTopicConnection.java,1.12,1.13 ClusterPropagation.java,1.12,1.13 ClusterTopicConnectionFactory.java,1.8,1.9

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

Update of /cvsroot/ubermq/jms/src/com/ubermq/jms/server/cluster
In directory sc8-pr-cvs1:/tmp/cvs-serv28341/src/com/ubermq/jms/server/cluster

Modified Files:
	ClusterTopicConnection.java ClusterPropagation.java 
	ClusterTopicConnectionFactory.java 
Log Message:
bug fixes related to read/write initialization race conditions

Index: ClusterTopicConnection.java
===================================================================
RCS file: /cvsroot/ubermq/jms/src/com/ubermq/jms/server/cluster/ClusterTopicConnection.java,v
retrieving revision 1.12
retrieving revision 1.13
diff -C2 -d -r1.12 -r1.13
*** ClusterTopicConnection.java	31 Jan 2003 23:21:16 -0000	1.12
--- ClusterTopicConnection.java	21 Jan 2004 02:05:24 -0000	1.13
***************
*** 4,9 ****
  import com.ubermq.jms.client.unicast.*;
  import com.ubermq.jms.client.*;
! import com.ubermq.jms.server.datagram.*;
! import com.ubermq.jms.server.datagram.control.*;
  import com.ubermq.kernel.*;
  import com.ubermq.kernel.overflow.*;
--- 4,9 ----
  import com.ubermq.jms.client.unicast.*;
  import com.ubermq.jms.client.*;
! import com.ubermq.jms.common.datagram.*;
! import com.ubermq.jms.common.datagram.control.*;
  import com.ubermq.kernel.*;
  import com.ubermq.kernel.overflow.*;

Index: ClusterPropagation.java
===================================================================
RCS file: /cvsroot/ubermq/jms/src/com/ubermq/jms/server/cluster/ClusterPropagation.java,v
retrieving revision 1.12
retrieving revision 1.13
diff -C2 -d -r1.12 -r1.13
*** ClusterPropagation.java	12 Jan 2004 19:24:25 -0000	1.12
--- ClusterPropagation.java	21 Jan 2004 02:05:24 -0000	1.13
***************
*** 41,45 ****
          catch(Exception x)
          {
!             com.ubermq.Utility.getLogger().error("", x);;
          }
      }
--- 41,45 ----
          catch(Exception x)
          {
!             com.ubermq.util.Utility.getLogger().error("", x);;
          }
      }
***************
*** 69,73 ****
                          }
                          catch (JMSException e) {
!                             com.ubermq.Utility.getLogger().error("", e);;
                          }
                      }
--- 69,73 ----
                          }
                          catch (JMSException e) {
!                             com.ubermq.util.Utility.getLogger().error("", e);;
                          }
                      }

Index: ClusterTopicConnectionFactory.java
===================================================================
RCS file: /cvsroot/ubermq/jms/src/com/ubermq/jms/server/cluster/ClusterTopicConnectionFactory.java,v
retrieving revision 1.8
retrieving revision 1.9
diff -C2 -d -r1.8 -r1.9
*** ClusterTopicConnectionFactory.java	31 Jan 2003 23:21:16 -0000	1.8
--- ClusterTopicConnectionFactory.java	21 Jan 2004 02:05:24 -0000	1.9
***************
*** 22,26 ****
      public ClusterTopicConnectionFactory(String url)
      {
!         this.icd = new SimpleInternetConnectionDescriptor(url, com.ubermq.jms.server.MessageServer.DEFAULT_PORT);
      }
  
--- 22,26 ----
      public ClusterTopicConnectionFactory(String url)
      {
!         this.icd = new SimpleInternetConnectionDescriptor(url, com.ubermq.jms.common.MessageConstants.DEFAULT_PORT);
      }