[jBoss-Dev] CVS update: spyderMQ/src/java/org/spydermq Log.javaSpyDistributedConnection.java JMSServerQueue.java

[jBoss CVS Development]

  User: norbert 
  Date: 00/06/14 21:02:29

  Modified:    src/java/org/spydermq Log.java SpyDistributedConnection.java
                        JMSServerQueue.java
  Log:
  Very first step for the Optimized Invocation Layer
  It only works for the ConnectionReceiver object
  
  Revision  Changes    Path
  1.5       +2 -2      spyderMQ/src/java/org/spydermq/Log.java
  
  Index: Log.java
  ===================================================================
  RCS file: /products/cvs/ejboss/spyderMQ/src/java/org/spydermq/Log.java,v
  retrieving revision 1.4
  retrieving revision 1.5
  diff -u -r1.4 -r1.5
  --- Log.java  2000/06/15 00:45:02     1.4
  +++ Log.java  2000/06/15 04:02:28     1.5
  @@ -12,7 +12,7 @@
    *      
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.4 $
  + *   @version $Revision: 1.5 $
    */
   public class Log
   {
  @@ -21,7 +21,7 @@
        final static int LOG_ERRORS             = 3;
        
        //Change this line change the verbosity level
  -     final static int logType = LOG_ERRORS;
  +     final static int logType = LOG_EVERYTHING;
        
        private static void print(Object obj)
        {
  
  
  
  1.3       +3 -1      spyderMQ/src/java/org/spydermq/SpyDistributedConnection.java
  
  Index: SpyDistributedConnection.java
  ===================================================================
  RCS file: 
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/SpyDistributedConnection.java,v
  retrieving revision 1.2
  retrieving revision 1.3
  diff -u -r1.2 -r1.3
  --- SpyDistributedConnection.java     2000/06/01 00:04:40     1.2
  +++ SpyDistributedConnection.java     2000/06/15 04:02:28     1.3
  @@ -14,11 +14,13 @@
    *      
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.2 $
  + *   @version $Revision: 1.3 $
    */
   public class SpyDistributedConnection 
        implements Serializable
   {
  +     //NL : Do a better HashCode() and equals() !
  +     
        private String clientID;
        public ConnectionReceiver cr;
        public transient boolean listeners;
  
  
  
  1.10      +3 -3      spyderMQ/src/java/org/spydermq/JMSServerQueue.java
  
  Index: JMSServerQueue.java
  ===================================================================
  RCS file: /products/cvs/ejboss/spyderMQ/src/java/org/spydermq/JMSServerQueue.java,v
  retrieving revision 1.9
  retrieving revision 1.10
  diff -u -r1.9 -r1.10
  --- JMSServerQueue.java       2000/06/15 00:45:02     1.9
  +++ JMSServerQueue.java       2000/06/15 04:02:29     1.10
  @@ -18,14 +18,14 @@
    *      
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.9 $
  + *   @version $Revision: 1.10 $
    */
   public class JMSServerQueue
   {
        // Attributes ----------------------------------------------------
   
        //the Destination of this queue
  -     Destination destination;
  +     SpyDestination destination;
        //DistributedConnection objs that have "registered" to this Destination
        private HashMap subscribers;
        //List of Pending messages
  @@ -48,7 +48,7 @@
        
        // Constructor ---------------------------------------------------
           
  -     JMSServerQueue(Destination dest,SpyDistributedConnection temporary,JMSServer 
server)
  +     JMSServerQueue(SpyDestination dest,SpyDistributedConnection 
temporary,JMSServer server)
        {
                destination=dest;
                subscribers=new HashMap();