[jBoss-Dev] CVS update:spyderMQ/src/java/org/spydermq/distributed ConnectionReceiverFactory.javaJMSServerFactory.java

[jBoss CVS Development]

  User: norbert 
  Date: 00/06/18 21:23:13

  Modified:    src/java/org/spydermq/distributed
                        ConnectionReceiverFactory.java
                        JMSServerFactory.java
  Log:
  More work for the OIL
  
  Revision  Changes    Path
  1.3       +3 -1      
spyderMQ/src/java/org/spydermq/distributed/ConnectionReceiverFactory.java
  
  Index: ConnectionReceiverFactory.java
  ===================================================================
  RCS file: 
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/distributed/ConnectionReceiverFactory.java,v
  retrieving revision 1.2
  retrieving revision 1.3
  diff -u -r1.2 -r1.3
  --- ConnectionReceiverFactory.java    2000/06/15 22:50:30     1.2
  +++ ConnectionReceiverFactory.java    2000/06/19 04:23:13     1.3
  @@ -9,6 +9,7 @@
   import org.spydermq.distributed.interfaces.ConnectionReceiver;
   import org.spydermq.SpyConnection;
   import org.spydermq.SpyDistributedConnection;
  +import org.spydermq.Log;
   import java.util.Properties;
   import java.rmi.server.UnicastRemoteObject;
   import java.rmi.Remote;
  @@ -18,7 +19,7 @@
    *      
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.2 $
  + *   @version $Revision: 1.3 $
    */
   public class ConnectionReceiverFactory
   {
  @@ -27,6 +28,7 @@
        
        public static SpyDistributedConnection createDistributedConnection(String 
clientID, SpyConnection connection, String crClassName) throws Exception
        {
  +             Log.error("Create "+crClassName);
                ConnectionReceiver cr = 
(ConnectionReceiver)Class.forName(crClassName).newInstance();
                cr.setConnection(connection);           
                SpyDistributedConnection distributedConnection=new 
SpyDistributedConnection(clientID,cr);
  
  
  
  1.2       +9 -1      spyderMQ/src/java/org/spydermq/distributed/JMSServerFactory.java
  
  Index: JMSServerFactory.java
  ===================================================================
  RCS file: 
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/distributed/JMSServerFactory.java,v
  retrieving revision 1.1
  retrieving revision 1.2
  diff -u -r1.1 -r1.2
  --- JMSServerFactory.java     2000/05/31 18:10:13     1.1
  +++ JMSServerFactory.java     2000/06/19 04:23:13     1.2
  @@ -15,7 +15,7 @@
    *      
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.1 $
  + *   @version $Revision: 1.2 $
    */
   public class JMSServerFactory
   {
  @@ -28,4 +28,12 @@
                jmss.setServer(s);
                return jmss;
        }
  +     
  +     
  +             /*Log.error("Create "+crClassName);
  +             ConnectionReceiver cr = 
(ConnectionReceiver)Class.forName(crClassName).newInstance();
  +             cr.setConnection(connection);           
  +             SpyDistributedConnection distributedConnection=new 
SpyDistributedConnection(clientID,cr);
  +             distributedConnection.setConnectionReceiver(cr.createClient()); 
  +             return distributedConnection;   */
   }