[Ubermq-commits] jms/src/com/ubermq/kernel AbstractConnectionInfo.java,1.5,1.6

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

Update of /cvsroot/ubermq/jms/src/com/ubermq/kernel
In directory usw-pr-cvs1:/tmp/cvs-serv32625/src/com/ubermq/kernel

Modified Files:
	AbstractConnectionInfo.java 
Log Message:
fix for unbound publishers, selector case sensitivity bug


Index: AbstractConnectionInfo.java
===================================================================
RCS file: /cvsroot/ubermq/jms/src/com/ubermq/kernel/AbstractConnectionInfo.java,v
retrieving revision 1.5
retrieving revision 1.6
diff -C2 -d -r1.5 -r1.6
*** AbstractConnectionInfo.java	6 Sep 2002 15:55:59 -0000	1.5
--- AbstractConnectionInfo.java	8 Sep 2002 20:51:50 -0000	1.6
***************
*** 51,60 ****
      {
  		readBuffer = r;
! 		readBuffer.clear();
! 		readMutex = new Mutex();
  		
  		writeBuffer = w;
! 		writeBuffer.clear();
! 		writeMutex = new Mutex();
  		
  		id = String.valueOf(allocateProcessUniqueId());
--- 51,64 ----
      {
  		readBuffer = r;
! 		if (readBuffer != null) {
! 			readBuffer.clear();
! 			readMutex = new Mutex();
! 		}
  		
  		writeBuffer = w;
! 		if (writeBuffer != null) {
! 			writeBuffer.clear();
! 			writeMutex = new Mutex();
! 		}
  		
  		id = String.valueOf(allocateProcessUniqueId());