class InsertMessage extends RequestMessage
RequestMessage.EncodingMetadata, RequestMessage.OpCode| Modifier and Type | Field and Description |
|---|---|
private java.util.List<InsertRequest> |
insertRequestList |
private boolean |
ordered |
private WriteConcern |
writeConcern |
REQUEST_ID| Constructor and Description |
|---|
InsertMessage(java.lang.String collectionName,
boolean ordered,
WriteConcern writeConcern,
java.util.List<InsertRequest> insertRequestList,
MessageSettings settings)
Construct an instance.
|
| Modifier and Type | Method and Description |
|---|---|
private FieldNameValidator |
createValidator() |
protected RequestMessage |
encodeMessageBody(BsonOutput outputStream,
int messageStartPosition)
Encode the message body to the given output.
|
protected RequestMessage.EncodingMetadata |
encodeMessageBodyWithMetadata(BsonOutput outputStream,
int messageStartPosition)
Encode the message body to the given output.
|
java.util.List<InsertRequest> |
getInsertRequestList() |
private void |
writeInsertPrologue(BsonOutput outputStream) |
addCollectibleDocument, addDocument, backpatchMessageLength, encode, encodeWithMetadata, getCodec, getCollectionName, getCurrentGlobalId, getId, getNamespace, getOpCode, getSettings, writeMessagePrologueprivate final boolean ordered
private final WriteConcern writeConcern
private final java.util.List<InsertRequest> insertRequestList
public InsertMessage(java.lang.String collectionName,
boolean ordered,
WriteConcern writeConcern,
java.util.List<InsertRequest> insertRequestList,
MessageSettings settings)
collectionName - the full name of the collectionordered - whether the inserts are orderedwriteConcern - the write concerninsertRequestList - the list of insert requestssettings - the message settingspublic java.util.List<InsertRequest> getInsertRequestList()
protected RequestMessage encodeMessageBody(BsonOutput outputStream, int messageStartPosition)
RequestMessageencodeMessageBody in class RequestMessageoutputStream - the outputmessageStartPosition - the start position of the messageprotected RequestMessage.EncodingMetadata encodeMessageBodyWithMetadata(BsonOutput outputStream, int messageStartPosition)
RequestMessageencodeMessageBodyWithMetadata in class RequestMessageoutputStream - the outputmessageStartPosition - the start position of the messageprivate FieldNameValidator createValidator()
private void writeInsertPrologue(BsonOutput outputStream)