class CompressedMessage extends RequestMessage
RequestMessage.EncodingMetadata
Modifier and Type | Field and Description |
---|---|
private Compressor |
compressor |
private java.util.List<ByteBuf> |
wrappedMessageBuffers |
private OpCode |
wrappedOpcode |
MESSAGE_PROLOGUE_LENGTH, REQUEST_ID
Constructor and Description |
---|
CompressedMessage(OpCode wrappedOpcode,
java.util.List<ByteBuf> wrappedMessageBuffers,
Compressor compressor,
MessageSettings settings) |
Modifier and Type | Method and Description |
---|---|
protected RequestMessage.EncodingMetadata |
encodeMessageBodyWithMetadata(BsonOutput bsonOutput,
SessionContext sessionContext)
Encode the message body to the given output.
|
private static ByteBuf |
getFirstWrappedMessageBuffer(java.util.List<ByteBuf> wrappedMessageBuffers) |
private static int |
getWrappedMessageRequestId(java.util.List<ByteBuf> wrappedMessageBuffers) |
private static int |
getWrappedMessageSize(java.util.List<ByteBuf> wrappedMessageBuffers) |
addCollectibleDocument, addDocument, addDocument, backpatchMessageLength, encode, getCodec, getCollectionName, getCurrentGlobalId, getEncodingMetadata, getId, getNamespace, getOpCode, getSettings, writeMessagePrologue
private final OpCode wrappedOpcode
private final java.util.List<ByteBuf> wrappedMessageBuffers
private final Compressor compressor
CompressedMessage(OpCode wrappedOpcode, java.util.List<ByteBuf> wrappedMessageBuffers, Compressor compressor, MessageSettings settings)
protected RequestMessage.EncodingMetadata encodeMessageBodyWithMetadata(BsonOutput bsonOutput, SessionContext sessionContext)
RequestMessage
encodeMessageBodyWithMetadata
in class RequestMessage
bsonOutput
- the outputsessionContext
- the session contextprivate static int getWrappedMessageSize(java.util.List<ByteBuf> wrappedMessageBuffers)
private static int getWrappedMessageRequestId(java.util.List<ByteBuf> wrappedMessageBuffers)