com.caucho.amqp.io
Class AmqpFrameReader

java.lang.Object
  extended by java.io.InputStream
      extended by com.caucho.amqp.io.AmqpFrameReader
All Implemented Interfaces:
java.io.Closeable

public class AmqpFrameReader
extends java.io.InputStream


Constructor Summary
AmqpFrameReader()
           
AmqpFrameReader(ReadStream is)
           
 
Method Summary
 void finishFrame()
           
 int getOffset()
           
 int getSize()
           
 void init(ReadStream is)
           
 int read()
           
 boolean startFrame()
           
 
Methods inherited from class java.io.InputStream
available, close, mark, markSupported, read, read, reset, skip
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AmqpFrameReader

public AmqpFrameReader()

AmqpFrameReader

public AmqpFrameReader(ReadStream is)
Method Detail

init

public void init(ReadStream is)

getSize

public int getSize()

getOffset

public int getOffset()

startFrame

public boolean startFrame()
                   throws java.io.IOException
Throws:
java.io.IOException

finishFrame

public void finishFrame()
                 throws java.io.IOException
Throws:
java.io.IOException

read

public int read()
         throws java.io.IOException
Specified by:
read in class java.io.InputStream
Throws:
java.io.IOException