com.mongodb

Class BaseWriteCommandMessage

java.lang.Object

com.mongodb.RequestMessage

com.mongodb.BaseWriteCommandMessage

Direct Known Subclasses:

DeleteCommandMessage, InsertCommandMessage, UpdateCommandMessage

abstract class BaseWriteCommandMessage
extends RequestMessage

Nested Class Summary

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

RequestMessage.OpCode

Field Summary

Fields

Modifier and Type	Field and Description
private java.lang.Boolean	bypassDocumentValidation
private DBEncoder	commandEncoder
private static int	HEADROOM
private WriteConcern	writeConcern
private MongoNamespace	writeNamespace

Fields inherited from class com.mongodb.RequestMessage

REQUEST_ID

Constructor Summary

Constructors

Constructor and Description
BaseWriteCommandMessage(MongoNamespace writeNamespace, WriteConcern writeConcern, java.lang.Boolean bypassDocumentValidation, DBEncoder commandEncoder, MessageSettings settings)

Method Summary

Modifier and Type	Method and Description
BaseWriteCommandMessage	encode(OutputBuffer buffer)
protected BaseWriteCommandMessage	encodeMessageBody(OutputBuffer buffer, int messageStartPosition)
private boolean	exceedsBatchItemCountLimit(int batchItemCount)
private boolean	exceedsBatchLengthLimit(int batchLength, int batchItemCount)
protected boolean	exceedsLimits(int batchLength, int batchItemCount)
protected java.lang.Boolean	getBypassDocumentValidation()
DBEncoder	getCommandEncoder()
protected abstract java.lang.String	getCommandName()
abstract int	getItemCount()
WriteConcern	getWriteConcern()
MongoNamespace	getWriteNamespace()
private void	writeCommandHeader(OutputBuffer buffer)
private void	writeCommandPrologue(BSONBinaryWriter writer)
protected abstract BaseWriteCommandMessage	writeTheWrites(OutputBuffer buffer, int commandStartPosition, BSONBinaryWriter writer)

Methods inherited from class com.mongodb.RequestMessage

backpatchMessageLength, getCollectionName, 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

HEADROOM

private static final int HEADROOM

See Also:

Constant Field Values

writeNamespace

private final MongoNamespace writeNamespace

writeConcern

private final WriteConcern writeConcern

bypassDocumentValidation

private final java.lang.Boolean bypassDocumentValidation

commandEncoder

private final DBEncoder commandEncoder

Constructor Detail

BaseWriteCommandMessage

public BaseWriteCommandMessage(MongoNamespace writeNamespace,
                               WriteConcern writeConcern,
                               java.lang.Boolean bypassDocumentValidation,
                               DBEncoder commandEncoder,
                               MessageSettings settings)

Method Detail

getWriteNamespace

public MongoNamespace getWriteNamespace()

getWriteConcern

public WriteConcern getWriteConcern()

getCommandEncoder

public DBEncoder getCommandEncoder()

encode

public BaseWriteCommandMessage encode(OutputBuffer buffer)

Overrides:

encode in class RequestMessage

encodeMessageBody

protected BaseWriteCommandMessage encodeMessageBody(OutputBuffer buffer,
                                                    int messageStartPosition)

Specified by:

encodeMessageBody in class RequestMessage

writeCommandHeader

private void writeCommandHeader(OutputBuffer buffer)

getCommandName

protected abstract java.lang.String getCommandName()

getBypassDocumentValidation

protected java.lang.Boolean getBypassDocumentValidation()

writeTheWrites

protected abstract BaseWriteCommandMessage writeTheWrites(OutputBuffer buffer,
                                                          int commandStartPosition,
                                                          BSONBinaryWriter writer)

exceedsLimits

protected boolean exceedsLimits(int batchLength,
                                int batchItemCount)

exceedsBatchLengthLimit

private boolean exceedsBatchLengthLimit(int batchLength,
                                        int batchItemCount)

exceedsBatchItemCountLimit

private boolean exceedsBatchItemCountLimit(int batchItemCount)

getItemCount

public abstract int getItemCount()

writeCommandPrologue

private void writeCommandPrologue(BSONBinaryWriter writer)