Package | Description |
---|---|
com.mongodb.connection |
Contains classes that manage connecting to MongoDB servers.
|
Modifier and Type | Field and Description |
---|---|
private CommandMessage |
CommandProtocol.CommandResultCallback.message |
Modifier and Type | Method and Description |
---|---|
private static CommandMessage |
CommandHelper.sendMessage(java.lang.String database,
BsonDocument command,
InternalConnection internalConnection) |
Modifier and Type | Method and Description |
---|---|
private static <D> D |
CommandProtocol.getResponseDocument(ResponseBuffers responseBuffers,
CommandMessage commandMessage,
Decoder<D> decoder) |
private static BsonDocument |
CommandHelper.receiveCommandDocument(InternalConnection internalConnection,
CommandMessage message) |
private static BsonDocument |
CommandHelper.receiveCommandResult(InternalConnection internalConnection,
CommandMessage message) |
private static ReplyMessage<BsonDocument> |
CommandHelper.receiveReply(InternalConnection internalConnection,
CommandMessage message) |
private static void |
CommandHelper.receiveReplyAsync(InternalConnection internalConnection,
CommandMessage message,
SingleResultCallback<ReplyMessage<BsonDocument>> callback) |
private void |
CommandProtocol.sendFailedEvent(ConnectionDescription connectionDescription,
long startTimeNanos,
CommandMessage commandMessage,
java.lang.Throwable t) |
private void |
CommandProtocol.sendMessage(CommandMessage message,
InternalConnection connection) |
private void |
CommandProtocol.sendStartedEvent(InternalConnection connection,
ByteBufferBsonOutput bsonOutput,
CommandMessage message,
int documentPosition) |
private void |
CommandProtocol.sendSucceededEvent(ConnectionDescription connectionDescription,
long startTimeNanos,
CommandMessage commandMessage,
BsonDocument response) |
Modifier and Type | Method and Description |
---|---|
private static void |
CommandHelper.sendMessageAsync(java.lang.String database,
BsonDocument command,
InternalConnection internalConnection,
SingleResultCallback<CommandMessage> callback) |
Constructor and Description |
---|
CommandResultCallback(SingleResultCallback<T> callback,
CommandMessage message,
ConnectionDescription connectionDescription,
long startTimeNanos) |