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

[jBoss CVS Development]

  User: norbert 
  Date: 00/05/17 19:10:05

  Modified:    src/java/org/spyderMQ/distributed
                        ConnectionReceiverFactory.java
  Log:
  Fix the Connection. Now it unexpoort unused objects :)
  
  Revision  Changes    Path
  1.5       +10 -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.4
  retrieving revision 1.5
  diff -u -r1.4 -r1.5
  --- ConnectionReceiverFactory.java    2000/05/09 00:09:03     1.4
  +++ ConnectionReceiverFactory.java    2000/05/18 02:10:05     1.5
  @@ -8,14 +8,17 @@
   
   import org.spydermq.distributed.interfaces.ConnectionReceiver;
   import org.spydermq.SpyConnection;
  +import org.spydermq.SpyDistributedConnection;
   import java.util.Properties;
  +import java.rmi.server.UnicastRemoteObject;
  +import java.rmi.Remote;
   
   /**
    *   This is a factory for the ConnectionReceiver interface
    *      
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.4 $
  + *   @version $Revision: 1.5 $
    */
   public class ConnectionReceiverFactory
   {
  @@ -27,5 +30,11 @@
                ConnectionReceiver cr = 
(ConnectionReceiver)Class.forName(crClassName).newInstance();
                cr.setConnection(c);
                return cr;
  +     }
  +     
  +     public static void close(SpyDistributedConnection dc) throws Exception
  +     {
  +             dc.cr.close();                  
  +             UnicastRemoteObject.unexportObject(((Remote)dc.cr),true);
        }
   }