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

[jBoss CVS Development]

  User: norbert 
  Date: 00/06/19 14:51:58

  Modified:    src/java/org/spydermq Log.java SpyConnection.java
                        SpyDistributedConnection.java
  Log:
  OIL... the next step
  
  Revision  Changes    Path
  1.7       +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.6
  retrieving revision 1.7
  diff -u -r1.6 -r1.7
  --- Log.java  2000/06/19 04:23:12     1.6
  +++ Log.java  2000/06/19 21:51:57     1.7
  @@ -12,7 +12,7 @@
    *      
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.6 $
  + *   @version $Revision: 1.7 $
    */
   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.9       +3 -3      spyderMQ/src/java/org/spydermq/SpyConnection.java
  
  Index: SpyConnection.java
  ===================================================================
  RCS file: /products/cvs/ejboss/spyderMQ/src/java/org/spydermq/SpyConnection.java,v
  retrieving revision 1.8
  retrieving revision 1.9
  diff -u -r1.8 -r1.9
  --- SpyConnection.java        2000/06/19 04:23:12     1.8
  +++ SpyConnection.java        2000/06/19 21:51:57     1.9
  @@ -29,10 +29,10 @@
    *      
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.8 $
  + *   @version $Revision: 1.9 $
    */
   public class SpyConnection 
  -             implements Connection, Serializable
  +     implements Connection, Serializable
   {
   
        // Attributes ----------------------------------------------------
  @@ -293,7 +293,7 @@
                                        HashMap 
newDestinations=(HashMap)destinations.clone();
                                        newDestinations.put(dest,connectionQueue);
                                        destinations=newDestinations;
  -                                     
provider.subscribe(dest,distributedConnection);                 
  +                                     provider.subscribe(dest,distributedConnection);
                                } else {                        
                                        connectionQueue.addSession(who);               
         
                                }
  
  
  
  1.5       +7 -6      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.4
  retrieving revision 1.5
  diff -u -r1.4 -r1.5
  --- SpyDistributedConnection.java     2000/06/15 22:50:29     1.4
  +++ SpyDistributedConnection.java     2000/06/19 21:51:58     1.5
  @@ -7,6 +7,7 @@
   package org.spydermq;
   
   import org.spydermq.distributed.interfaces.ConnectionReceiver;
  +import org.spydermq.distributed.interfaces.ConnectionReceiverSetup;
   import java.io.Serializable;
   
   /**
  @@ -14,22 +15,22 @@
    *      
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.4 $
  + *   @version $Revision: 1.5 $
    */
   public class SpyDistributedConnection 
        implements Serializable
   {
        
        private String clientID;
  -     public transient ConnectionReceiver cr_;
  -     public ConnectionReceiver cr;
  +     private int hash;
  +     public transient ConnectionReceiverSetup cr_server;
        public transient boolean listeners;
  -     protected int hash;
  +     public ConnectionReceiver cr;
        
  -     public SpyDistributedConnection(String clientID,ConnectionReceiver cr)
  +     public SpyDistributedConnection(String clientID,ConnectionReceiverSetup 
cr_server)
        {
                this.clientID=clientID;
  -             this.cr_=cr;
  +             this.cr_server=cr_server;
                if (clientID==null) hash=0;
                else hash=clientID.hashCode();
        }