[jBoss-Dev] CVS update: spyderMQ/src/java/org/spydermq/serverMain.java

[jBoss CVS Development]

  User: norbert 
  Date: 00/06/19 14:52:01

  Modified:    src/java/org/spydermq/server Main.java
  Log:
  OIL... the next step
  
  Revision  Changes    Path
  1.10      +6 -3      spyderMQ/src/java/org/spydermq/server/Main.java
  
  Index: Main.java
  ===================================================================
  RCS file: /products/cvs/ejboss/spyderMQ/src/java/org/spydermq/server/Main.java,v
  retrieving revision 1.9
  retrieving revision 1.10
  diff -u -r1.9 -r1.10
  --- Main.java 2000/06/19 04:23:16     1.9
  +++ Main.java 2000/06/19 21:52:01     1.10
  @@ -10,6 +10,7 @@
   import org.spydermq.JMSServer;
   import org.spydermq.security.SecurityManager;
   import org.spydermq.distributed.interfaces.DistributedJMSServer;
  +import org.spydermq.distributed.interfaces.DistributedJMSServerSetup;
   import org.spydermq.distributed.interfaces.DistributedTopicConnectionFactory;
   import org.spydermq.distributed.interfaces.DistributedQueueConnectionFactory;
   import org.spydermq.distributed.JMSServerFactory;
  @@ -43,7 +44,7 @@
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    *   @author Rich Johns ([EMAIL PROTECTED])
    *
  - *   @version $Revision: 1.9 $
  + *   @version $Revision: 1.10 $
    */
   public class Main implements Runnable
   {
  @@ -51,6 +52,7 @@
        SpyQueueConnectionFactory queueConnectionFactory;
        DistributedTopicConnectionFactory distributedTopicConnectionFactory;
        DistributedQueueConnectionFactory distributedQueueConnectionFactory;
  +     DistributedJMSServerSetup theDistributedServerSetup;
        DistributedJMSServer theDistributedServer;
        SecurityManager securityManager;
        JMSServer theServer;
  @@ -120,10 +122,11 @@
   
                        //Create the JMSServer object
                        theServer = new JMSServer(securityManager);
  -                     theDistributedServer = 
JMSServerFactory.createJMSServer(theServer,cfg);
  +                     theDistributedServerSetup = 
JMSServerFactory.createJMSServer(theServer,cfg);
  +                     theDistributedServer=theDistributedServerSetup.createClient();
                        String 
connectionReceiverCN=(String)cfg.get("ConnectionReceiverClassName");
                        mBeanServer.registerMBean(theServer, new 
ObjectName(JMSServer.OBJECT_NAME));
  -                     mBeanServer.registerMBean(theDistributedServer, new 
ObjectName("JMS:service=DistributedJMSServer"));
  +                     mBeanServer.registerMBean(theDistributedServerSetup, new 
ObjectName("JMS:service=DistributedJMSServerSetup"));
                
                        //Get the Topic properties
                        String 
topicConnectionFactoryCN=(String)cfg.get("DistributedTopicConnectionFactoryClassName");