User: chirino
Date: 01/05/22 17:25:48
Modified: src/main/org/jbossmq/multiplexor StreamDemux.java
Log:
"Patrick J. McNerthney" <[EMAIL PROTECTED]> reported/fix a
bug with the StreamDemux. The streams were not getting properly
closed
Revision Changes Path
1.3 +2 -2 jbossmq/src/main/org/jbossmq/multiplexor/StreamDemux.java
Index: StreamDemux.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jbossmq/multiplexor/StreamDemux.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- StreamDemux.java 2001/03/02 01:12:57 1.2
+++ StreamDemux.java 2001/05/23 00:25:48 1.3
@@ -15,7 +15,7 @@
*
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.2 $
+ * @version $Revision: 1.3 $
*/
public class StreamDemux {
@@ -121,7 +121,7 @@
case StreamMux.CLOSE_STREAM_COMMAND :
DemuxInputStream s;
synchronized (openStreams) {
- s = (DemuxInputStream)
openStreams.get(new Short(streamId));
+ s = (DemuxInputStream)
openStreams.get(new Short(objectIn.readShort()));
}
if (s != null) {
closeStream(s.streamId);
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development
