Package | Description |
---|---|
com.mongodb.connection |
Contains classes that manage connecting to MongoDB servers.
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
BaseQueryMessage
Base class for OP_QUERY messages.
|
(package private) class |
BaseWriteCommandMessage
Abstract base class for write command message.
|
(package private) class |
CommandMessage
A command message that uses OP_QUERY to send the command.
|
(package private) class |
DeleteCommandMessage
A message for the delete command.
|
(package private) class |
DeleteMessage
An OP_DELETE message.
|
(package private) class |
GetMoreMessage
An OP_GET_MORE message.
|
(package private) class |
InsertCommandMessage
An insert command message.
|
(package private) class |
InsertMessage
An insert message.
|
(package private) class |
KillCursorsMessage
An OP_KILL_CURSOR message.
|
(package private) class |
QueryMessage
An OP_QUERY message for an actual query (not a command).
|
(package private) class |
UpdateCommandMessage
A message for the update command.
|
(package private) class |
UpdateMessage
An OP_UPDATE message.
|
Modifier and Type | Field and Description |
---|---|
private RequestMessage |
SendMessageCallback.message |
private RequestMessage |
WriteProtocol.WriteResultCallback.message |
private RequestMessage |
WriteProtocol.UnacknowledgedWriteResultCallback.message |
private RequestMessage |
RequestMessage.EncodingMetadata.nextMessage |
private RequestMessage |
WriteProtocol.WriteResultCallback.nextMessage |
private RequestMessage |
WriteProtocol.UnacknowledgedWriteResultCallback.nextMessage |
Modifier and Type | Method and Description |
---|---|
protected RequestMessage |
DeleteProtocol.createRequestMessage(MessageSettings settings) |
protected RequestMessage |
InsertProtocol.createRequestMessage(MessageSettings settings) |
protected RequestMessage |
UpdateProtocol.createRequestMessage(MessageSettings settings) |
protected abstract RequestMessage |
WriteProtocol.createRequestMessage(MessageSettings settings)
Create the initial request message for the write.
|
RequestMessage |
RequestMessage.encode(BsonOutput bsonOutput)
Encoded the message to the given output.
|
(package private) static RequestMessage |
ProtocolHelper.encodeMessage(RequestMessage message,
BsonOutput bsonOutput) |
protected RequestMessage |
QueryMessage.encodeMessageBody(BsonOutput bsonOutput,
int messageStartPosition) |
protected RequestMessage |
InsertMessage.encodeMessageBody(BsonOutput outputStream,
int messageStartPosition) |
protected RequestMessage |
UpdateMessage.encodeMessageBody(BsonOutput bsonOutput,
int messageStartPosition) |
protected RequestMessage |
CommandMessage.encodeMessageBody(BsonOutput bsonOutput,
int messageStartPosition) |
protected RequestMessage |
GetMoreMessage.encodeMessageBody(BsonOutput bsonOutput,
int messageStartPosition) |
protected abstract RequestMessage |
RequestMessage.encodeMessageBody(BsonOutput bsonOutput,
int messageStartPosition)
Encode the message body to the given output.
|
protected RequestMessage |
DeleteMessage.encodeMessageBody(BsonOutput bsonOutput,
int messageStartPosition) |
protected RequestMessage |
KillCursorsMessage.encodeMessageBody(BsonOutput bsonOutput,
int messageStartPosition) |
RequestMessage |
RequestMessage.EncodingMetadata.getNextMessage() |
Modifier and Type | Method and Description |
---|---|
protected void |
DeleteProtocol.appendToWriteCommandResponseDocument(RequestMessage curMessage,
RequestMessage nextMessage,
WriteConcernResult writeConcernResult,
BsonDocument response) |
protected void |
InsertProtocol.appendToWriteCommandResponseDocument(RequestMessage curMessage,
RequestMessage nextMessage,
WriteConcernResult writeConcernResult,
BsonDocument response) |
protected void |
UpdateProtocol.appendToWriteCommandResponseDocument(RequestMessage curMessage,
RequestMessage nextMessage,
WriteConcernResult writeConcernResult,
BsonDocument response) |
protected abstract void |
WriteProtocol.appendToWriteCommandResponseDocument(RequestMessage curMessage,
RequestMessage nextMessage,
WriteConcernResult writeConcernResult,
BsonDocument response) |
(package private) static RequestMessage |
ProtocolHelper.encodeMessage(RequestMessage message,
BsonOutput bsonOutput) |
(package private) static RequestMessage.EncodingMetadata |
ProtocolHelper.encodeMessageWithMetadata(RequestMessage message,
BsonOutput bsonOutput) |
private void |
WriteProtocol.executeAsync(RequestMessage requestMessage,
InternalConnection connection,
SingleResultCallback<WriteConcernResult> callback) |
protected java.lang.String |
WriteProtocol.getCommandName(RequestMessage message) |
private BsonDocument |
WriteProtocol.getResponseDocument(RequestMessage curMessage,
RequestMessage nextMessage,
WriteConcernResult writeConcernResult,
WriteConcernException writeConcernException) |
private BsonDocument |
WriteCommandProtocol.receiveMessage(InternalConnection connection,
RequestMessage message) |
(package private) static void |
ProtocolHelper.sendCommandFailedEvent(RequestMessage message,
java.lang.String commandName,
ConnectionDescription connectionDescription,
long startTimeNanos,
java.lang.Throwable throwable,
CommandListener commandListener) |
(package private) static void |
ProtocolHelper.sendCommandStartedEvent(RequestMessage message,
java.lang.String databaseName,
java.lang.String commandName,
BsonDocument command,
ConnectionDescription connectionDescription,
CommandListener commandListener) |
(package private) static void |
ProtocolHelper.sendCommandSucceededEvent(RequestMessage message,
java.lang.String commandName,
BsonDocument response,
ConnectionDescription connectionDescription,
long startTimeNanos,
CommandListener commandListener) |
private void |
WriteProtocol.sendFailedEvent(InternalConnection connection,
RequestMessage message,
boolean sentCommandStartedEvent,
java.lang.Throwable t,
long startTimeNanos) |
private void |
WriteProtocol.sendStartedEvent(InternalConnection connection,
RequestMessage message,
RequestMessage.EncodingMetadata encodingMetadata,
ByteBufferBsonOutput bsonOutput) |
private void |
WriteProtocol.sendSucceededEvent(InternalConnection connection,
RequestMessage message,
BsonDocument responseDocument,
long startTimeNanos) |
private void |
WriteProtocol.sendSucceededEvent(InternalConnection connection,
RequestMessage message,
RequestMessage nextMessage,
WriteConcernException e,
long startTimeNanos) |
private void |
WriteProtocol.sendSucceededEvent(InternalConnection connection,
RequestMessage message,
RequestMessage nextMessage,
WriteConcernResult writeConcernResult,
long startTimeNanos) |
private boolean |
WriteProtocol.shouldAcknowledge(RequestMessage nextMessage) |
Constructor and Description |
---|
EncodingMetadata(RequestMessage nextMessage,
int firstDocumentPosition) |
SendMessageCallback(InternalConnection connection,
OutputBuffer buffer,
RequestMessage message,
int requestId,
java.lang.String commandName,
long startTimeNanos,
CommandListener commandListener,
SingleResultCallback<T> callback,
SingleResultCallback<ResponseBuffers> receiveMessageCallback) |
SendMessageCallback(InternalConnection connection,
OutputBuffer buffer,
RequestMessage message,
java.lang.String commandName,
long startTimeNanos,
CommandListener commandListener,
SingleResultCallback<T> callback,
SingleResultCallback<ResponseBuffers> receiveMessageCallback) |
UnacknowledgedWriteResultCallback(SingleResultCallback<WriteConcernResult> callback,
RequestMessage message,
RequestMessage nextMessage,
OutputBuffer writtenBuffer,
InternalConnection connection,
long startTimeNanos) |
WriteResultCallback(SingleResultCallback<WriteConcernResult> callback,
Decoder<BsonDocument> decoder,
RequestMessage message,
RequestMessage nextMessage,
long requestId,
InternalConnection connection,
long startTimeNanos) |