User: norbert
Date: 00/05/17 19:10:04
Modified: src/java/org/spyderMQ SpyConnection.java
SpyDistributedConnection.java
Log:
Fix the Connection. Now it unexpoort unused objects :)
Revision Changes Path
1.28 +3 -9 spyderMQ/src/java/org/spyderMQ/SpyConnection.java
Index: SpyConnection.java
===================================================================
RCS file: /products/cvs/ejboss/spyderMQ/src/java/org/spyderMQ/SpyConnection.java,v
retrieving revision 1.27
retrieving revision 1.28
diff -u -r1.27 -r1.28
--- SpyConnection.java 2000/05/16 03:31:00 1.27
+++ SpyConnection.java 2000/05/18 02:10:04 1.28
@@ -29,7 +29,7 @@
*
* @author Norbert Lataille ([EMAIL PROTECTED])
*
- * @version $Revision: 1.27 $
+ * @version $Revision: 1.28 $
*/
public class SpyConnection
implements Connection, Serializable
@@ -163,19 +163,13 @@
}
- //close the connection receiver object
- try {
- distributedConnection.cr.close();
- } catch (Exception e) {
- failureHandler(e,"Cannot close() the ConnectionReceiver");
- }
-
//Notify the JMSServer that I am closing
try {
provider.connectionClosing(distributedConnection);
+ ConnectionReceiverFactory.close(distributedConnection);
} catch (Exception e) {
failureHandler(e,"Cannot close properly the connection");
- }
+ }
}
1.4 +2 -2 spyderMQ/src/java/org/spyderMQ/SpyDistributedConnection.java
Index: SpyDistributedConnection.java
===================================================================
RCS file:
/products/cvs/ejboss/spyderMQ/src/java/org/spyderMQ/SpyDistributedConnection.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- SpyDistributedConnection.java 2000/05/15 22:56:53 1.3
+++ SpyDistributedConnection.java 2000/05/18 02:10:04 1.4
@@ -14,13 +14,13 @@
*
* @author Norbert Lataille ([EMAIL PROTECTED])
*
- * @version $Revision: 1.3 $
+ * @version $Revision: 1.4 $
*/
public class SpyDistributedConnection
implements Serializable
{
private String clientID;
- ConnectionReceiver cr;
+ public ConnectionReceiver cr;
SpyDistributedConnection(String id,ConnectionReceiver cr_)
{