com.caucho.amqp.io
Class AmqpFrameWriter

java.lang.Object
  extended by java.io.OutputStream
      extended by com.caucho.amqp.io.AmqpBaseWriter
          extended by com.caucho.amqp.io.AmqpFrameWriter
All Implemented Interfaces:
java.io.Closeable, java.io.Flushable

public class AmqpFrameWriter
extends AmqpBaseWriter


Constructor Summary
AmqpFrameWriter()
           
AmqpFrameWriter(WriteStream os)
           
 
Method Summary
 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