[Ubermq-commits] jms/src/com/ubermq/jms/server/routing/impl ConnectionDestNode.java,1.9,1.10 SelectorDestNode.java,1.4,1.5 SimpleSelector.java,1.5,1.6

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

Update of /cvsroot/ubermq/jms/src/com/ubermq/jms/server/routing/impl
In directory sc8-pr-cvs1:/tmp/cvs-serv28765/src/com/ubermq/jms/server/routing/impl

Modified Files:
	ConnectionDestNode.java SelectorDestNode.java 
	SimpleSelector.java 
Log Message:
improvements on spin detection.


Index: ConnectionDestNode.java
===================================================================
RCS file: /cvsroot/ubermq/jms/src/com/ubermq/jms/server/routing/impl/ConnectionDestNode.java,v
retrieving revision 1.9
retrieving revision 1.10
diff -C2 -d -r1.9 -r1.10
*** ConnectionDestNode.java	26 Oct 2002 15:54:13 -0000	1.9
--- ConnectionDestNode.java	12 Jan 2004 19:24:25 -0000	1.10
***************
*** 29,33 ****
      public String getDisplayName() {return conn.toString();}
      public String getNodeName() {return conn.getId();}
!     public String toString() {return "Connection-" + conn.getId();}
  
      public boolean equals(Object o)
--- 29,33 ----
      public String getDisplayName() {return conn.toString();}
      public String getNodeName() {return conn.getId();}
!     public String toString() {return conn.toString();}
  
      public boolean equals(Object o)

Index: SelectorDestNode.java
===================================================================
RCS file: /cvsroot/ubermq/jms/src/com/ubermq/jms/server/routing/impl/SelectorDestNode.java,v
retrieving revision 1.4
retrieving revision 1.5
diff -C2 -d -r1.4 -r1.5
*** SelectorDestNode.java	30 Jan 2003 14:42:24 -0000	1.4
--- SelectorDestNode.java	12 Jan 2004 19:24:25 -0000	1.5
***************
*** 18,22 ****
          this.selector = new SimpleSelector(selector);
  
!         com.ubermq.Utility.getLogger().fine("selector is  " + this.selector.toString());
      }
  
--- 18,22 ----
          this.selector = new SimpleSelector(selector);
  
!         com.ubermq.Utility.getLogger().debug("selector is  " + this.selector.toString());
      }
  
***************
*** 30,34 ****
          if (d instanceof IMessageDatagram) {
              boolean accept = selector.accept((IMessageDatagram)d);
!             com.ubermq.Utility.getLogger().fine("selector returned " + accept);
  
              if (!accept) return;
--- 30,34 ----
          if (d instanceof IMessageDatagram) {
              boolean accept = selector.accept((IMessageDatagram)d);
!             com.ubermq.Utility.getLogger().debug("selector returned " + accept);
  
              if (!accept) return;

Index: SimpleSelector.java
===================================================================
RCS file: /cvsroot/ubermq/jms/src/com/ubermq/jms/server/routing/impl/SimpleSelector.java,v
retrieving revision 1.5
retrieving revision 1.6
diff -C2 -d -r1.5 -r1.6
*** SimpleSelector.java	30 Jan 2003 14:42:24 -0000	1.5
--- SimpleSelector.java	12 Jan 2004 19:24:25 -0000	1.6
***************
*** 71,75 ****
          }
  
!         com.ubermq.Utility.getLogger().fine("selector comparing " + property + " containing " + value + " with " + scalar);
  
          if (value == null || scalar == null) {
--- 71,75 ----
          }
  
!         com.ubermq.Utility.getLogger().debug("selector comparing " + property + " containing " + value + " with " + scalar);
  
          if (value == null || scalar == null) {