com.mongodb.connection

Class CompressedMessage

java.lang.Object

com.mongodb.connection.RequestMessage

com.mongodb.connection.CompressedMessage

class CompressedMessage
extends RequestMessage

Nested Class Summary

Nested classes/interfaces inherited from class com.mongodb.connection.RequestMessage

RequestMessage.EncodingMetadata

Field Summary

Fields

Modifier and Type	Field and Description
private Compressor	compressor
private java.util.List<ByteBuf>	wrappedMessageBuffers
private OpCode	wrappedOpcode

Fields inherited from class com.mongodb.connection.RequestMessage

MESSAGE_PROLOGUE_LENGTH, REQUEST_ID

Constructor Summary

Constructors

Constructor and Description
CompressedMessage(OpCode wrappedOpcode, java.util.List<ByteBuf> wrappedMessageBuffers, Compressor compressor, MessageSettings settings)

Method Summary

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)

Methods inherited from class com.mongodb.connection.RequestMessage

addCollectibleDocument, addDocument, addDocument, backpatchMessageLength, encode, getCodec, getCollectionName, getCurrentGlobalId, getEncodingMetadata, getId, getNamespace, getOpCode, getSettings, writeMessagePrologue

Methods inherited from class java.lang.Object

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

Field Detail

wrappedOpcode

private final OpCode wrappedOpcode

wrappedMessageBuffers

private final java.util.List<ByteBuf> wrappedMessageBuffers

compressor

private final Compressor compressor

Constructor Detail

CompressedMessage

CompressedMessage(OpCode wrappedOpcode,
                  java.util.List<ByteBuf> wrappedMessageBuffers,
                  Compressor compressor,
                  MessageSettings settings)

Method Detail

encodeMessageBodyWithMetadata

protected RequestMessage.EncodingMetadata encodeMessageBodyWithMetadata(BsonOutput bsonOutput,
                                                                        SessionContext sessionContext)

Description copied from class: RequestMessage

Encode the message body to the given output.

Specified by:

encodeMessageBodyWithMetadata in class RequestMessage

Parameters:

bsonOutput - the output

sessionContext - the session context

Returns:

the encoding metadata

getWrappedMessageSize

private static int getWrappedMessageSize(java.util.List<ByteBuf> wrappedMessageBuffers)

getWrappedMessageRequestId

private static int getWrappedMessageRequestId(java.util.List<ByteBuf> wrappedMessageBuffers)

getFirstWrappedMessageBuffer

private static ByteBuf getFirstWrappedMessageBuffer(java.util.List<ByteBuf> wrappedMessageBuffers)