User: norbert 
  Date: 00/06/01 13:11:49

  Modified:    src/java/org/spydermq/server Main.java
  Log:
  Debug : Add the RemoteControl object
  
  Revision  Changes    Path
  1.4       +12 -10    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.3
  retrieving revision 1.4
  diff -u -r1.3 -r1.4
  --- Main.java 2000/06/01 02:38:50     1.3
  +++ Main.java 2000/06/01 20:11:49     1.4
  @@ -37,7 +37,7 @@
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    *   @author Rich Johns ([EMAIL PROTECTED])
    *
  - *   @version $Revision: 1.3 $
  + *   @version $Revision: 1.4 $
    */
   public class Main implements Runnable
   {
  @@ -52,11 +52,13 @@
        //We prevent garbage collection with a static variable
        //MF FIXME: use JMX to admin and prevent garbage collectionf
        private static Main thisServer;
  +
  +     //DEBUG -- For the RemoteControl object
  +     private static RemoteControlImpl remoteControl;
        
  -     //bind the TopicConnectionFactory object
  -     public void startJMSServer()
  +     public void run()
        {
  -             Log.log("SpyderMQ [v0.3]");
  +             Log.notice("SpyderMQ [v0.3]");
                
                try { 
                        
  @@ -72,7 +74,7 @@
                        if( (noStartJNDI == null) || (noStartJNDI.length() == 0) )
                        {
                                //Start the JNDI server
  -                             Log.log( "Starting JNDI Server (JNP)" );
  +                             Log.notice( "Starting JNDI Server (JNP)" );
                                new org.jnp.server.Main().start();
                        }
                        else
  @@ -184,17 +186,17 @@
                        //(re)bind the connection factories in the JNDI namespace
                        ctx.rebind("TopicConnectionFactory",topicConnectionFactory);
                        ctx.rebind("QueueConnectionFactory",queueConnectionFactory);
  +                     
  +                     //DEBUG -- Create a RemoteControl object
  +                     //Administration calls will soon be done using JMX.
  +                     remoteControl=new RemoteControlImpl(theServer);
  +                     ctx.rebind("RemoteControl",remoteControl);
   
                } catch (Exception e) { 
                        Log.error("Cannot start the JMS server ! "+e.getMessage()); 
                        Log.error(e); 
                } 
                
  -     }
  -     
  -     public void run()
  -     {
  -             startJMSServer();
        }
        
        public static void main(String[] args) throws Exception
  
  
  

Reply via email to