final class CommandHelper
extends java.lang.Object
Modifier | Constructor and Description |
---|---|
private |
CommandHelper() |
Modifier and Type | Method and Description |
---|---|
private static MongoCommandException |
createCommandFailureException(BsonDocument reply,
InternalConnection internalConnection) |
(package private) static BsonDocument |
executeCommand(java.lang.String database,
BsonDocument command,
InternalConnection internalConnection) |
(package private) static void |
executeCommandAsync(java.lang.String database,
BsonDocument command,
InternalConnection internalConnection,
SingleResultCallback<BsonDocument> callback) |
(package private) static BsonDocument |
executeCommandWithoutCheckingForFailure(java.lang.String database,
BsonDocument command,
InternalConnection internalConnection) |
(package private) static boolean |
isCommandOk(BsonDocument response) |
private static BsonDocument |
receiveCommandDocument(InternalConnection internalConnection,
CommandMessage message) |
private static BsonDocument |
receiveCommandResult(InternalConnection internalConnection,
CommandMessage message) |
private static ReplyMessage<BsonDocument> |
receiveReply(InternalConnection internalConnection,
CommandMessage message) |
private static void |
receiveReplyAsync(InternalConnection internalConnection,
CommandMessage message,
SingleResultCallback<ReplyMessage<BsonDocument>> callback) |
private static CommandMessage |
sendMessage(java.lang.String database,
BsonDocument command,
InternalConnection internalConnection) |
private static void |
sendMessageAsync(java.lang.String database,
BsonDocument command,
InternalConnection internalConnection,
SingleResultCallback<CommandMessage> callback) |
static BsonDocument executeCommand(java.lang.String database, BsonDocument command, InternalConnection internalConnection)
static void executeCommandAsync(java.lang.String database, BsonDocument command, InternalConnection internalConnection, SingleResultCallback<BsonDocument> callback)
static BsonDocument executeCommandWithoutCheckingForFailure(java.lang.String database, BsonDocument command, InternalConnection internalConnection)
static boolean isCommandOk(BsonDocument response)
private static CommandMessage sendMessage(java.lang.String database, BsonDocument command, InternalConnection internalConnection)
private static void sendMessageAsync(java.lang.String database, BsonDocument command, InternalConnection internalConnection, SingleResultCallback<CommandMessage> callback)
private static BsonDocument receiveCommandResult(InternalConnection internalConnection, CommandMessage message)
private static BsonDocument receiveCommandDocument(InternalConnection internalConnection, CommandMessage message)
private static ReplyMessage<BsonDocument> receiveReply(InternalConnection internalConnection, CommandMessage message)
private static void receiveReplyAsync(InternalConnection internalConnection, CommandMessage message, SingleResultCallback<ReplyMessage<BsonDocument>> callback)
private static MongoCommandException createCommandFailureException(BsonDocument reply, InternalConnection internalConnection)