final class ProtocolHelper
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private static Logger |
PROTOCOL_EVENT_LOGGER |
private static CodecRegistry |
REGISTRY |
Modifier | Constructor and Description |
---|---|
private |
ProtocolHelper() |
Modifier and Type | Method and Description |
---|---|
private static MongoException |
createSpecialException(BsonDocument response,
ServerAddress serverAddress,
java.lang.String errorMessageFieldName) |
private static WriteConcernResult |
createWriteResult(BsonDocument result) |
(package private) static RequestMessage |
encodeMessage(RequestMessage message,
BsonOutput bsonOutput) |
(package private) static RequestMessage.EncodingMetadata |
encodeMessageWithMetadata(RequestMessage message,
BsonOutput bsonOutput) |
(package private) static MongoException |
getCommandFailureException(BsonDocument response,
ServerAddress serverAddress) |
(package private) static int |
getErrorCode(BsonDocument response) |
(package private) static java.lang.String |
getErrorMessage(BsonDocument response,
java.lang.String errorMessageFieldName) |
private static BsonValue |
getField(BsonReader bsonReader,
java.lang.String fieldName) |
(package private) static MessageSettings |
getMessageSettings(ConnectionDescription connectionDescription) |
(package private) static MongoException |
getQueryFailureException(BsonDocument errorDocument,
ServerAddress serverAddress) |
(package private) static WriteConcernResult |
getWriteResult(BsonDocument result,
ServerAddress serverAddress) |
private static boolean |
hasWriteError(BsonDocument response) |
(package private) static boolean |
isCommandOk(BsonDocument response) |
(package private) static boolean |
isCommandOk(BsonReader bsonReader) |
private static boolean |
isCommandOk(BsonValue okValue) |
(package private) static void |
sendCommandFailedEvent(RequestMessage message,
java.lang.String commandName,
ConnectionDescription connectionDescription,
long startTimeNanos,
java.lang.Throwable throwable,
CommandListener commandListener) |
(package private) static void |
sendCommandStartedEvent(RequestMessage message,
java.lang.String databaseName,
java.lang.String commandName,
BsonDocument command,
ConnectionDescription connectionDescription,
CommandListener commandListener) |
(package private) static void |
sendCommandSucceededEvent(RequestMessage message,
java.lang.String commandName,
BsonDocument response,
ConnectionDescription connectionDescription,
long startTimeNanos,
CommandListener commandListener) |
private static void |
throwWriteException(BsonDocument result,
ServerAddress serverAddress) |
private static final Logger PROTOCOL_EVENT_LOGGER
private static final CodecRegistry REGISTRY
static WriteConcernResult getWriteResult(BsonDocument result, ServerAddress serverAddress)
private static WriteConcernResult createWriteResult(BsonDocument result)
static boolean isCommandOk(BsonDocument response)
static boolean isCommandOk(BsonReader bsonReader)
private static BsonValue getField(BsonReader bsonReader, java.lang.String fieldName)
private static boolean isCommandOk(BsonValue okValue)
static MongoException getCommandFailureException(BsonDocument response, ServerAddress serverAddress)
static int getErrorCode(BsonDocument response)
static java.lang.String getErrorMessage(BsonDocument response, java.lang.String errorMessageFieldName)
static MongoException getQueryFailureException(BsonDocument errorDocument, ServerAddress serverAddress)
static MessageSettings getMessageSettings(ConnectionDescription connectionDescription)
static RequestMessage encodeMessage(RequestMessage message, BsonOutput bsonOutput)
static RequestMessage.EncodingMetadata encodeMessageWithMetadata(RequestMessage message, BsonOutput bsonOutput)
private static MongoException createSpecialException(BsonDocument response, ServerAddress serverAddress, java.lang.String errorMessageFieldName)
private static boolean hasWriteError(BsonDocument response)
private static void throwWriteException(BsonDocument result, ServerAddress serverAddress)
static void sendCommandStartedEvent(RequestMessage message, java.lang.String databaseName, java.lang.String commandName, BsonDocument command, ConnectionDescription connectionDescription, CommandListener commandListener)
static void sendCommandSucceededEvent(RequestMessage message, java.lang.String commandName, BsonDocument response, ConnectionDescription connectionDescription, long startTimeNanos, CommandListener commandListener)
static void sendCommandFailedEvent(RequestMessage message, java.lang.String commandName, ConnectionDescription connectionDescription, long startTimeNanos, java.lang.Throwable throwable, CommandListener commandListener)