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

[jBoss CVS Development]

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

  Modified:    src/java/org/spydermq/distributed
                        ConnectionReceiverFactory.java
                        JMSServerFactory.java
  Log:
  OIL... the next step
  
  Revision  Changes    Path
  1.4       +4 -3      
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.3
  retrieving revision 1.4
  diff -u -r1.3 -r1.4
  --- ConnectionReceiverFactory.java    2000/06/19 04:23:13     1.3
  +++ ConnectionReceiverFactory.java    2000/06/19 21:51:58     1.4
  @@ -7,6 +7,7 @@
   package org.spydermq.distributed;
   
   import org.spydermq.distributed.interfaces.ConnectionReceiver;
  +import org.spydermq.distributed.interfaces.ConnectionReceiverSetup;
   import org.spydermq.SpyConnection;
   import org.spydermq.SpyDistributedConnection;
   import org.spydermq.Log;
  @@ -19,7 +20,7 @@
    *      
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.3 $
  + *   @version $Revision: 1.4 $
    */
   public class ConnectionReceiverFactory
   {
  @@ -29,8 +30,8 @@
        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);           
  +             ConnectionReceiverSetup cr = 
(ConnectionReceiverSetup)Class.forName(crClassName).newInstance();
  +             cr.setConnection(connection);
                SpyDistributedConnection distributedConnection=new 
SpyDistributedConnection(clientID,cr);
                distributedConnection.setConnectionReceiver(cr.createClient()); 
                return distributedConnection;
  
  
  
  1.3       +6 -10     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.2
  retrieving revision 1.3
  diff -u -r1.2 -r1.3
  --- JMSServerFactory.java     2000/06/19 04:23:13     1.2
  +++ JMSServerFactory.java     2000/06/19 21:51:58     1.3
  @@ -7,7 +7,9 @@
   package org.spydermq.distributed;
   
   import org.spydermq.distributed.interfaces.DistributedJMSServer;
  +import org.spydermq.distributed.interfaces.DistributedJMSServerSetup;
   import org.spydermq.JMSServer;
  +import org.spydermq.Log;
   import java.util.Properties;
   
   /**
  @@ -15,25 +17,19 @@
    *      
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.2 $
  + *   @version $Revision: 1.3 $
    */
   public class JMSServerFactory
   {
        // Static -------------------------------------------------------
   
  -     public static DistributedJMSServer createJMSServer(JMSServer s,Properties 
prop) throws Exception
  +     public static DistributedJMSServerSetup createJMSServer(JMSServer s,Properties 
prop) throws Exception
        {
                String className=(String)prop.get("DistributedJMSServerClassName");
  -             DistributedJMSServer jmss = 
(DistributedJMSServer)Class.forName(className).newInstance();
  +             Log.error("Create "+className);
  +             DistributedJMSServerSetup jmss = 
(DistributedJMSServerSetup)Class.forName(className).newInstance();
                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;   */
   }