[Ubermq-commits] jms/src/com/ubermq/jms/client/msg LocalMapMessage.java,1.6,1.7 LocalStreamMessage.java,1.6,1.7 LocalTextMessage.java,1.9,1.10 LocalBytesMessage.java,1.6,1.7 AbstractStreamMessage.java,1.9,1.10 LocalObjectMessage.java,1.9,1.10

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

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

Modified Files:
	LocalMapMessage.java LocalStreamMessage.java 
	LocalTextMessage.java LocalBytesMessage.java 
	AbstractStreamMessage.java LocalObjectMessage.java 
Log Message:
bug fixes related to read/write initialization race conditions

Index: LocalMapMessage.java
===================================================================
RCS file: /cvsroot/ubermq/jms/src/com/ubermq/jms/client/msg/LocalMapMessage.java,v
retrieving revision 1.6
retrieving revision 1.7
diff -C2 -d -r1.6 -r1.7
*** LocalMapMessage.java	30 Jan 2003 14:42:18 -0000	1.6
--- LocalMapMessage.java	21 Jan 2004 02:05:25 -0000	1.7
***************
*** 3,7 ****
  import com.ubermq.jms.client.*;
  import com.ubermq.jms.client.impl.*;
! import com.ubermq.jms.server.datagram.*;
  import java.util.*;
  import javax.jms.*;
--- 3,7 ----
  import com.ubermq.jms.client.*;
  import com.ubermq.jms.client.impl.*;
! import com.ubermq.jms.common.datagram.*;
  import java.util.*;
  import javax.jms.*;

Index: LocalStreamMessage.java
===================================================================
RCS file: /cvsroot/ubermq/jms/src/com/ubermq/jms/client/msg/LocalStreamMessage.java,v
retrieving revision 1.6
retrieving revision 1.7
diff -C2 -d -r1.6 -r1.7
*** LocalStreamMessage.java	30 Jan 2003 14:42:19 -0000	1.6
--- LocalStreamMessage.java	21 Jan 2004 02:05:25 -0000	1.7
***************
*** 2,6 ****
  
  import com.ubermq.jms.client.*;
! import com.ubermq.jms.server.datagram.*;
  import java.io.*;
  import javax.jms.*;
--- 2,6 ----
  
  import com.ubermq.jms.client.*;
! import com.ubermq.jms.common.datagram.*;
  import java.io.*;
  import javax.jms.*;

Index: LocalTextMessage.java
===================================================================
RCS file: /cvsroot/ubermq/jms/src/com/ubermq/jms/client/msg/LocalTextMessage.java,v
retrieving revision 1.9
retrieving revision 1.10
diff -C2 -d -r1.9 -r1.10
*** LocalTextMessage.java	7 May 2003 17:41:46 -0000	1.9
--- LocalTextMessage.java	21 Jan 2004 02:05:25 -0000	1.10
***************
*** 1,9 ****
  package com.ubermq.jms.client.msg;
  
- import com.ubermq.Utility;
  import com.ubermq.jms.client.IAcknowledgeHandler;
  import com.ubermq.jms.client.impl.LocalMessage;
! import com.ubermq.jms.server.datagram.IMessageDatagram;
! import com.ubermq.jms.server.datagram.IMessageDatagramFactory;
  import javax.jms.JMSException;
  import javax.jms.MessageNotWriteableException;
--- 1,10 ----
  package com.ubermq.jms.client.msg;
  
  import com.ubermq.jms.client.IAcknowledgeHandler;
  import com.ubermq.jms.client.impl.LocalMessage;
! import com.ubermq.jms.common.datagram.IMessageDatagram;
! import com.ubermq.jms.common.datagram.IMessageDatagramFactory;
! import com.ubermq.util.*;
! 
  import javax.jms.JMSException;
  import javax.jms.MessageNotWriteableException;

Index: LocalBytesMessage.java
===================================================================
RCS file: /cvsroot/ubermq/jms/src/com/ubermq/jms/client/msg/LocalBytesMessage.java,v
retrieving revision 1.6
retrieving revision 1.7
diff -C2 -d -r1.6 -r1.7
*** LocalBytesMessage.java	17 Dec 2002 14:52:24 -0000	1.6
--- LocalBytesMessage.java	21 Jan 2004 02:05:25 -0000	1.7
***************
*** 2,6 ****
  
  import com.ubermq.jms.client.*;
! import com.ubermq.jms.server.datagram.*;
  
  /**
--- 2,6 ----
  
  import com.ubermq.jms.client.*;
! import com.ubermq.jms.common.datagram.*;
  
  /**

Index: AbstractStreamMessage.java
===================================================================
RCS file: /cvsroot/ubermq/jms/src/com/ubermq/jms/client/msg/AbstractStreamMessage.java,v
retrieving revision 1.9
retrieving revision 1.10
diff -C2 -d -r1.9 -r1.10
*** AbstractStreamMessage.java	14 Feb 2003 13:33:22 -0000	1.9
--- AbstractStreamMessage.java	21 Jan 2004 02:05:25 -0000	1.10
***************
*** 4,8 ****
  import com.ubermq.jms.client.*;
  import com.ubermq.jms.client.impl.*;
! import com.ubermq.jms.server.datagram.*;
  import java.io.*;
  import java.nio.*;
--- 4,10 ----
  import com.ubermq.jms.client.*;
  import com.ubermq.jms.client.impl.*;
! import com.ubermq.jms.common.datagram.*;
! import com.ubermq.util.*;
! 
  import java.io.*;
  import java.nio.*;

Index: LocalObjectMessage.java
===================================================================
RCS file: /cvsroot/ubermq/jms/src/com/ubermq/jms/client/msg/LocalObjectMessage.java,v
retrieving revision 1.9
retrieving revision 1.10
diff -C2 -d -r1.9 -r1.10
*** LocalObjectMessage.java	30 Jan 2003 14:42:19 -0000	1.9
--- LocalObjectMessage.java	21 Jan 2004 02:05:25 -0000	1.10
***************
*** 2,6 ****
  import com.ubermq.jms.client.*;
  import com.ubermq.jms.client.impl.*;
! import com.ubermq.jms.server.datagram.*;
  import javax.jms.*;
  
--- 2,6 ----
  import com.ubermq.jms.client.*;
  import com.ubermq.jms.client.impl.*;
! import com.ubermq.jms.common.datagram.*;
  import javax.jms.*;