com.caucho.amqp.io

Class AmqpFrameReader

java.lang.Object

java.io.InputStream

com.caucho.amqp.io.AmqpFrameReader

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class AmqpFrameReader
extends java.io.InputStream

Constructor Summary

Constructors

Constructor and Description
AmqpFrameReader()
AmqpFrameReader(ReadStream is)

Method Summary

Modifier and Type	Method and Description
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