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 BsonBinaryReader |
createBsonReader(ResponseBuffers responseBuffers) |
private static MongoException |
createSpecialException(BsonDocument response,
ServerAddress serverAddress,
java.lang.String errorMessageFieldName) |
private static WriteConcernResult |
createWriteResult(BsonDocument result) |
(package private) static void |
encodeMessage(RequestMessage message,
BsonOutput bsonOutput) |
(package private) static RequestMessage.EncodingMetadata |
encodeMessageWithMetadata(RequestMessage message,
BsonOutput bsonOutput) |
(package private) static BsonDocument |
getClusterTime(BsonDocument response) |
(package private) static BsonDocument |
getClusterTime(ResponseBuffers responseBuffers) |
(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 BsonTimestamp |
getOperationTime(ResponseBuffers responseBuffers) |
(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 boolean |
isCommandOk(ResponseBuffers responseBuffers) |
(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)
static boolean isCommandOk(ResponseBuffers responseBuffers)
static BsonTimestamp getOperationTime(ResponseBuffers responseBuffers)
static BsonDocument getClusterTime(ResponseBuffers responseBuffers)
static BsonDocument getClusterTime(BsonDocument response)
private static BsonBinaryReader createBsonReader(ResponseBuffers responseBuffers)
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 void 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)