User: chirino
Date: 01/09/26 21:09:36
Modified: src/main/org/jboss/mq/il/oil OILServerIL.java
Log:
Cleaning up the ILs a little bit. It was reported that client connections
were not being closed properly on Linux. We are now explicitly closing
the serverIL sockets on the OIL and UIL ILs.
Revision Changes Path
1.4 +16 -2 jbossmq/src/main/org/jboss/mq/il/oil/OILServerIL.java
Index: OILServerIL.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jboss/mq/il/oil/OILServerIL.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- OILServerIL.java 2001/09/26 05:02:28 1.3
+++ OILServerIL.java 2001/09/27 04:09:36 1.4
@@ -37,7 +37,7 @@
*
* @author Hiram Chirino ([EMAIL PROTECTED])
* @author Norbert Lataille ([EMAIL PROTECTED])
- * @version $Revision: 1.3 $
+ * @version $Revision: 1.4 $
* @created August 16, 2001
*/
public class OILServerIL implements java.io.Serializable, Cloneable,
org.jboss.mq.il.ServerIL
@@ -303,6 +303,7 @@
checkConnection();
out.writeByte(m_connectionClosing);
waitAnswer();
+ destroyConnection();
}
/**
@@ -475,7 +476,7 @@
}
/**
- * #Description of the Method
+ * Used to establish a new connection to the server
*
* @exception Exception Description of Exception
*/
@@ -486,6 +487,19 @@
in = new ObjectInputStream(new BufferedInputStream(socket.getInputStream()));
out = new ObjectOutputStream(new
BufferedOutputStream(socket.getOutputStream()));
out.flush();
+ }
+
+ /**
+ * Used to close the current connection with the server
+ *
+ * @exception Exception Description of Exception
+ */
+ protected void destroyConnection()
+ throws Exception
+ {
+ out.close();
+ in.close();
+ socket.close();
}
/**
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
