class InsertProtocol extends WriteProtocol
Modifier and Type | Field and Description |
---|---|
private InsertRequest |
insertRequest |
private static Logger |
LOGGER |
Constructor and Description |
---|
InsertProtocol(MongoNamespace namespace,
boolean ordered,
InsertRequest insertRequest) |
Modifier and Type | Method and Description |
---|---|
protected RequestMessage |
createRequestMessage(MessageSettings settings)
Create the initial request message for the write.
|
WriteConcernResult |
execute(InternalConnection connection) |
void |
executeAsync(InternalConnection connection,
SingleResultCallback<WriteConcernResult> callback) |
protected BsonDocument |
getAsWriteCommand(ByteBufferBsonOutput bsonOutput,
int firstDocumentPosition) |
protected Logger |
getLogger()
Gets the logger.
|
getBaseCommandDocument, getCommandName, getNamespace, isOrdered, setCommandListener
private static final Logger LOGGER
private final InsertRequest insertRequest
InsertProtocol(MongoNamespace namespace, boolean ordered, InsertRequest insertRequest)
public WriteConcernResult execute(InternalConnection connection)
execute
in interface LegacyProtocol<WriteConcernResult>
execute
in class WriteProtocol
public void executeAsync(InternalConnection connection, SingleResultCallback<WriteConcernResult> callback)
executeAsync
in interface LegacyProtocol<WriteConcernResult>
executeAsync
in class WriteProtocol
protected BsonDocument getAsWriteCommand(ByteBufferBsonOutput bsonOutput, int firstDocumentPosition)
getAsWriteCommand
in class WriteProtocol
protected RequestMessage createRequestMessage(MessageSettings settings)
WriteProtocol
createRequestMessage
in class WriteProtocol
settings
- the message settingsprotected Logger getLogger()
WriteProtocol
getLogger
in class WriteProtocol