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

[jBoss CVS Development]

  User: norbert 
  Date: 00/05/24 12:17:21

  Modified:    src/java/org/spyderMQ/server Main.java
  Log:
  Changes to the Pub/Sub System in order to implement P2P.
  Now, a SessionQueue is specific to an unique destination.
  This is a way to code 'local optimisations' too
  Added bug (I think) in acknowledge()
  
  Selectors :
  Remove the .getClass().getName() [ thx Rich ]
  
  Revision  Changes    Path
  1.4       +7 -6      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/05/24 02:51:32     1.3
  +++ Main.java 2000/05/24 19:17:21     1.4
  @@ -36,7 +36,7 @@
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    *   @author Rich Johns ([EMAIL PROTECTED])
    *
  - *   @version $Revision: 1.3 $
  + *   @version $Revision: 1.4 $
    */
   public class Main implements Runnable
   {
  @@ -47,14 +47,15 @@
        DistributedJMSServer theDistributedServer;
        SecurityManager securityManager;
        JMSServer theServer;
  -  //We prevent garbage collection with a static variable
  -  // MF FIXME: use JMX to admin and prevent garbage collectionf
  -  private static Main thisServer;
  +
  +     //We prevent garbage collection with a static variable
  +     //MF FIXME: use JMX to admin and prevent garbage collectionf
  +     private static Main thisServer;
        
        //bind the TopicConnectionFactory object
        public void startJMSServer()
        {
  -             System.out.println("SpyderMQ [v0.1]");
  +             System.out.println("SpyderMQ [v0.3]");
                
                try { 
                        
  @@ -203,7 +204,7 @@
        public static void main(String[] args) throws Exception
        {    
                thisServer = new Main();
  -    thisServer.run();
  +             thisServer.run();
        }
        
   }