Package | Description |
---|---|
com.mongodb.connection |
Contains classes that manage connecting to MongoDB servers.
|
Modifier and Type | Method and Description |
---|---|
protected RequestMessage.EncodingMetadata |
QueryMessage.encodeMessageBodyWithMetadata(BsonOutput bsonOutput,
int messageStartPosition) |
protected RequestMessage.EncodingMetadata |
InsertMessage.encodeMessageBodyWithMetadata(BsonOutput outputStream,
int messageStartPosition) |
protected RequestMessage.EncodingMetadata |
UpdateMessage.encodeMessageBodyWithMetadata(BsonOutput bsonOutput,
int messageStartPosition) |
protected RequestMessage.EncodingMetadata |
CommandMessage.encodeMessageBodyWithMetadata(BsonOutput bsonOutput,
int messageStartPosition) |
protected RequestMessage.EncodingMetadata |
GetMoreMessage.encodeMessageBodyWithMetadata(BsonOutput bsonOutput,
int messageStartPosition) |
protected abstract RequestMessage.EncodingMetadata |
RequestMessage.encodeMessageBodyWithMetadata(BsonOutput bsonOutput,
int messageStartPosition)
Encode the message body to the given output.
|
protected RequestMessage.EncodingMetadata |
BaseWriteCommandMessage.encodeMessageBodyWithMetadata(BsonOutput outputStream,
int messageStartPosition) |
protected RequestMessage.EncodingMetadata |
DeleteMessage.encodeMessageBodyWithMetadata(BsonOutput bsonOutput,
int messageStartPosition) |
protected RequestMessage.EncodingMetadata |
KillCursorsMessage.encodeMessageBodyWithMetadata(BsonOutput bsonOutput,
int messageStartPosition) |
(package private) static RequestMessage.EncodingMetadata |
ProtocolHelper.encodeMessageWithMetadata(RequestMessage message,
BsonOutput bsonOutput) |
RequestMessage.EncodingMetadata |
RequestMessage.encodeWithMetadata(BsonOutput bsonOutput)
Encoded the message to the given output.
|
Modifier and Type | Method and Description |
---|---|
private boolean |
QueryProtocol.sendQueryStartedEvent(InternalConnection connection,
QueryMessage message,
ByteBufferBsonOutput bsonOutput,
RequestMessage.EncodingMetadata metadata) |
private void |
WriteCommandProtocol.sendStartedEvent(InternalConnection connection,
BaseWriteCommandMessage message,
ByteBufferBsonOutput bsonOutput,
RequestMessage.EncodingMetadata encodingMetadata) |
private void |
WriteProtocol.sendStartedEvent(InternalConnection connection,
RequestMessage message,
RequestMessage.EncodingMetadata encodingMetadata,
ByteBufferBsonOutput bsonOutput) |