com.caucho.amqp.io

Class AmqpFrameWriter

java.lang.Object

java.io.OutputStream

com.caucho.amqp.io.AmqpBaseWriter

com.caucho.amqp.io.AmqpFrameWriter

All Implemented Interfaces:

java.io.Closeable, java.io.Flushable, java.lang.AutoCloseable

public class AmqpFrameWriter
extends AmqpBaseWriter

Constructor Summary

Constructors

Constructor and Description
AmqpFrameWriter()
AmqpFrameWriter(WriteStream os)

Method Summary

Modifier and Type	Method and Description
void	finishFrame()
void	flush()
int	getOffset()
void	init(WriteStream os)
void	startFrame(int type)
void	startFrame(int type, int channel)
int	write(java.io.InputStream is)
void	write(int ch)
void	writeByte(int offset, int value)

Methods inherited from class com.caucho.amqp.io.AmqpBaseWriter

shiftRight, writeInt

Methods inherited from class java.io.OutputStream

close, write, write

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AmqpFrameWriter

public AmqpFrameWriter()

AmqpFrameWriter

public AmqpFrameWriter(WriteStream os)

Method Detail

init

public void init(WriteStream os)

startFrame

public void startFrame(int type)

startFrame

public void startFrame(int type,
                       int channel)

finishFrame

public void finishFrame()
                 throws java.io.IOException

Throws:

java.io.IOException

write

public int write(java.io.InputStream is)
          throws java.io.IOException

Throws:

java.io.IOException

write

public void write(int ch)

Specified by:

write in class java.io.OutputStream

getOffset

public int getOffset()

Specified by:

getOffset in class AmqpBaseWriter

writeByte

public void writeByte(int offset,
                      int value)

Specified by:

writeByte in class AmqpBaseWriter

flush

public void flush()
           throws java.io.IOException

Specified by:

flush in interface java.io.Flushable

Overrides:

flush in class java.io.OutputStream

Throws:

java.io.IOException