public class MessageFramer extends Object implements Framer
MessageFramer.Sink
.Modifier and Type | Class and Description |
---|---|
static interface |
MessageFramer.Sink
Sink implemented by the transport layer to receive frames and forward them to their
destination.
|
Constructor and Description |
---|
MessageFramer(MessageFramer.Sink sink,
WritableBufferAllocator bufferAllocator,
StatsTraceContext statsTraceCtx)
Creates a
MessageFramer . |
Modifier and Type | Method and Description |
---|---|
void |
close()
Flushes and closes the framer and releases any buffers.
|
void |
dispose()
Closes the framer and releases any buffers, but does not flush.
|
void |
flush()
Flushes any buffered data in the framer to the sink.
|
boolean |
isClosed()
|
MessageFramer |
setCompressor(Compressor compressor)
Set the compressor used for compression.
|
void |
setMaxOutboundMessageSize(int maxSize)
Set a size limit for each outbound message.
|
MessageFramer |
setMessageCompression(boolean enable)
Enable or disable compression.
|
void |
writePayload(InputStream message)
Writes out a payload message.
|
public MessageFramer(MessageFramer.Sink sink, WritableBufferAllocator bufferAllocator, StatsTraceContext statsTraceCtx)
MessageFramer
.sink
- the sink used to deliver frames to the transportbufferAllocator
- allocates buffers that the transport can commit to the wire.public MessageFramer setCompressor(Compressor compressor)
Framer
setCompressor
in interface Framer
public MessageFramer setMessageCompression(boolean enable)
Framer
setMessageCompression
in interface Framer
public void setMaxOutboundMessageSize(int maxSize)
Framer
setMaxOutboundMessageSize
in interface Framer
public void writePayload(InputStream message)
writePayload
in interface Framer
message
- contains the message to be written out. It will be completely consumed.public void flush()
public void close()
Copyright © 2019. All rights reserved.