User: hiram
Date: 00/11/19 12:00:06
Modified: src/java/org/spydermq/multiplexor StreamMux.java
DemuxInputStream.java MultiplexorTest.java
MuxOutputStream.java SocketMultiplexor.java
StreamDemux.java
Log:
Commiting several changes:
- Removed ConnectionQueue and SessionQueue. All consumer managment is done at the
SpyConnection now.
- Unacknowledged messages are maintained on the server side now.
(JMSServerQueueReceiver)
- Acknowlegment messages are sent to the server from the client.
- Optimized the OIL and UIL transports by caching the DistributedConnection on the
JMSServer when the ConnectionReciver is setup.
- Cleaned up the OIL by only using the Object(Output/Input) streams instead of both
Object(Output/Input) and Buffered(Output/Input) streams.
- A QueueReceiver now does a request for a single message on a receive() method
instead turning on/off listen to get a message.
- For the OIL and UIL, a connection failure/termination is now handled gracefully
(if connectionCLosing() was called, no errors shown, if it was not called and the
connection failed, we call it).
Revision Changes Path
1.2 +0 -0 spyderMQ/src/java/org/spydermq/multiplexor/StreamMux.java
Index: StreamMux.java
===================================================================
RCS file:
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/multiplexor/StreamMux.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- StreamMux.java 2000/11/16 22:43:36 1.1
+++ StreamMux.java 2000/11/19 20:00:04 1.2
@@ -15,7 +15,7 @@
*
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.1 $
+ * @version $Revision: 1.2 $
*/
public class StreamMux {
1.2 +0 -0 spyderMQ/src/java/org/spydermq/multiplexor/DemuxInputStream.java
Index: DemuxInputStream.java
===================================================================
RCS file:
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/multiplexor/DemuxInputStream.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- DemuxInputStream.java 2000/11/16 22:43:31 1.1
+++ DemuxInputStream.java 2000/11/19 20:00:05 1.2
@@ -18,7 +18,7 @@
*
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.1 $
+ * @version $Revision: 1.2 $
*/
class DemuxInputStream extends InputStream {
1.2 +0 -0 spyderMQ/src/java/org/spydermq/multiplexor/MultiplexorTest.java
Index: MultiplexorTest.java
===================================================================
RCS file:
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/multiplexor/MultiplexorTest.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- MultiplexorTest.java 2000/11/16 22:43:32 1.1
+++ MultiplexorTest.java 2000/11/19 20:00:05 1.2
@@ -29,7 +29,7 @@
*
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.1 $
+ * @version $Revision: 1.2 $
*/
public class MultiplexorTest {
1.2 +0 -0 spyderMQ/src/java/org/spydermq/multiplexor/MuxOutputStream.java
Index: MuxOutputStream.java
===================================================================
RCS file:
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/multiplexor/MuxOutputStream.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- MuxOutputStream.java 2000/11/16 22:43:32 1.1
+++ MuxOutputStream.java 2000/11/19 20:00:05 1.2
@@ -18,7 +18,7 @@
*
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.1 $
+ * @version $Revision: 1.2 $
*/
class MuxOutputStream extends OutputStream {
1.2 +5 -0
spyderMQ/src/java/org/spydermq/multiplexor/SocketMultiplexor.java
Index: SocketMultiplexor.java
===================================================================
RCS file:
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/multiplexor/SocketMultiplexor.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- SocketMultiplexor.java 2000/11/16 22:43:33 1.1
+++ SocketMultiplexor.java 2000/11/19 20:00:05 1.2
@@ -22,7 +22,7 @@
*
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.1 $
+ * @version $Revision: 1.2 $
*/
public class SocketMultiplexor {
@@ -67,4 +67,9 @@
public java.net.Socket getSocket() {
return socket;
}
+
+ public void close() throws IOException {
+ getSocket().close();
+ }
+
}
1.2 +0 -0 spyderMQ/src/java/org/spydermq/multiplexor/StreamDemux.java
Index: StreamDemux.java
===================================================================
RCS file:
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/multiplexor/StreamDemux.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- StreamDemux.java 2000/11/16 22:42:52 1.1
+++ StreamDemux.java 2000/11/19 20:00:05 1.2
@@ -15,7 +15,7 @@
*
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.1 $
+ * @version $Revision: 1.2 $
*/
public class StreamDemux {
