站内搜索: 请输入搜索关键词
当前页面: 在线文档首页 > JBoss 3.2.7 messaging API Documentation 英文版文档

StreamDemux (JBoss Messaging API) - JBoss 3.2.7 messaging API Documentation 英文版文档


org.jboss.mq.il.uil.multiplexor
Class StreamDemux

java.lang.Object
  extended byorg.jboss.mq.il.uil.multiplexor.StreamDemux

public class StreamDemux
extends Object

This class is used to demultiplex from a single stream into multiple streams.

Version:
$Revision: 1.3.4.1 $
Author:
Hiram Chirino (Cojonudo14@hotmail.com)

Constructor Summary
StreamDemux(InputStream in)
          StreamMux constructor comment.
 
Method Summary
 boolean attemptLock()
           
 int available(org.jboss.mq.il.uil.multiplexor.DemuxInputStream s)
           
 short getFrameSize()
          Creation date: (11/15/00 5:30:55 PM)
 InputStream getStream(short id)
           
 void pumpData(org.jboss.mq.il.uil.multiplexor.DemuxInputStream dest)
          Pumps data to all input streams until data for the dest Stream arrives.
 void releaseLock()
           
 void setFrameSize(short newFrameSize)
          Creation date: (11/15/00 5:30:55 PM)
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

StreamDemux

public StreamDemux(InputStream in)
            throws IOException
StreamMux constructor comment.

Parameters:
in - Description of Parameter
Throws:
IOException - Description of Exception
Method Detail

setFrameSize

public void setFrameSize(short newFrameSize)
                  throws IOException
Creation date: (11/15/00 5:30:55 PM)

Parameters:
newFrameSize - short
Throws:
IOException - Description of Exception

getFrameSize

public short getFrameSize()
Creation date: (11/15/00 5:30:55 PM)

Returns:
short

getStream

public InputStream getStream(short id)
                      throws IOException
Throws:
IOException

available

public int available(org.jboss.mq.il.uil.multiplexor.DemuxInputStream s)
              throws IOException
Throws:
IOException

attemptLock

public boolean attemptLock()
                    throws InterruptedIOException
Throws:
InterruptedIOException

releaseLock

public void releaseLock()

pumpData

public void pumpData(org.jboss.mq.il.uil.multiplexor.DemuxInputStream dest)
              throws IOException
Pumps data to all input streams until data for the dest Stream arrives. Only on thread is allowed to pump data at a time and this method returns true if it pumped data into its input buffer. It returns false if another thread is allready pumping data.

Parameters:
dest - Description of Parameter
Throws:
IOException - Description of Exception


Copyright © 2002 JBoss Group, LLC. All Rights Reserved.