FrameWriter

Writes Frames to an internal buffer for later processing by the transport.

class FrameWriter {

int DEFAULT_FRAME_BUFFER_FULL_MARK;

int FRAME_HEADER_SIZE;

byte AMQP_FRAME_TYPE;

byte SASL_FRAME_TYPE;

this(EncoderImpl encoder, int maxFrameSize, byte frameType, TransportImpl transport);

bool isFull();

int readBytes(ByteBuffer dst);

long getFramesOutput();

void setMaxFrameSize(int maxFrameSize);

void setFrameWriterMaxBytes(int maxBytes);

int getFrameWriterMaxBytes();

void writeHeader(byte[] header);

void writeFrame(Object frameBody);

void writeFrame(int channel, Object frameBody, ReadableBuffer payload, Runnable onPayloadTooLarge);

}

Constructors

this this(EncoderImpl encoder, int maxFrameSize, byte frameType, TransportImpl transport): Undocumented in source.

Members

Functions

getFrameWriterMaxBytes int getFrameWriterMaxBytes(): Undocumented in source. Be warned that the author may not have intended to support it.
getFramesOutput long getFramesOutput(): Undocumented in source. Be warned that the author may not have intended to support it.
isFull bool isFull(): Undocumented in source. Be warned that the author may not have intended to support it.
readBytes int readBytes(ByteBuffer dst): Undocumented in source. Be warned that the author may not have intended to support it.
setFrameWriterMaxBytes void setFrameWriterMaxBytes(int maxBytes): Undocumented in source. Be warned that the author may not have intended to support it.
setMaxFrameSize void setMaxFrameSize(int maxFrameSize): Undocumented in source. Be warned that the author may not have intended to support it.
writeFrame void writeFrame(Object frameBody): Undocumented in source. Be warned that the author may not have intended to support it.
writeFrame void writeFrame(int channel, Object frameBody, ReadableBuffer payload, Runnable onPayloadTooLarge): Undocumented in source. Be warned that the author may not have intended to support it.
writeHeader void writeHeader(byte[] header): Undocumented in source. Be warned that the author may not have intended to support it.

Static variables

AMQP_FRAME_TYPE byte AMQP_FRAME_TYPE;: Undocumented in source.
DEFAULT_FRAME_BUFFER_FULL_MARK int DEFAULT_FRAME_BUFFER_FULL_MARK;: Undocumented in source.
FRAME_HEADER_SIZE int FRAME_HEADER_SIZE;: Undocumented in source.
SASL_FRAME_TYPE byte SASL_FRAME_TYPE;: Undocumented in source.

Meta

Source

See Implementation

hunt proton engine impl FrameWriter classes

FrameWriter