Package | Description |
---|---|
com.mongodb.connection |
Contains classes that manage connecting to MongoDB servers.
|
Modifier and Type | Field and Description |
---|---|
private SingleResultCallback<ResponseBuffers> |
InternalStreamConnection.MessageHeaderCallback.callback |
private SingleResultCallback<ResponseBuffers> |
SendMessageCallback.receiveMessageCallback |
Modifier and Type | Method and Description |
---|---|
ResponseBuffers |
InternalConnection.receiveMessage(int responseTo)
Receive a response to a sent message from the server.
|
ResponseBuffers |
DefaultConnectionPool.PooledConnection.receiveMessage(int responseTo) |
ResponseBuffers |
InternalStreamConnection.receiveMessage(int responseTo) |
ResponseBuffers |
UsageTrackingInternalConnection.receiveMessage(int responseTo) |
private ResponseBuffers |
InternalStreamConnection.receiveResponseBuffers() |
Modifier and Type | Method and Description |
---|---|
private BsonDocument |
QueryProtocol.asFindCommandResponseDocument(ResponseBuffers responseBuffers,
QueryResult<T> queryResult,
boolean isExplain) |
private BsonDocument |
GetMoreProtocol.asGetMoreCommandResponseDocument(QueryResult<T> queryResult,
ResponseBuffers responseBuffers) |
protected void |
CommandResultBaseCallback.callCallback(ResponseBuffers responseBuffers,
java.lang.Throwable t) |
protected void |
GetMoreProtocol.GetMoreResultCallback.callCallback(ResponseBuffers responseBuffers,
java.lang.Throwable throwableFromCallback) |
protected void |
QueryProtocol.QueryResultCallback.callCallback(ResponseBuffers responseBuffers,
java.lang.Throwable throwableFromCallback) |
protected abstract void |
ResponseCallback.callCallback(ResponseBuffers responseBuffers,
java.lang.Throwable t) |
private static BsonBinaryReader |
ProtocolHelper.createBsonReader(ResponseBuffers responseBuffers) |
(package private) static java.util.List<ByteBufBsonDocument> |
ByteBufBsonDocument.createList(ResponseBuffers responseBuffers) |
(package private) static BsonDocument |
ProtocolHelper.getClusterTime(ResponseBuffers responseBuffers) |
(package private) static BsonTimestamp |
ProtocolHelper.getOperationTime(ResponseBuffers responseBuffers) |
private static <T extends BsonDocument> |
InternalStreamConnection.getResponseDocument(ResponseBuffers responseBuffers,
int messageId,
Decoder<T> decoder) |
(package private) static boolean |
ProtocolHelper.isCommandOk(ResponseBuffers responseBuffers) |
void |
ResponseCallback.onResult(ResponseBuffers responseBuffers,
java.lang.Throwable t) |
private void |
QueryProtocol.sendQuerySucceededEvent(ConnectionDescription connectionDescription,
long startTimeNanos,
QueryMessage message,
boolean isExplainEvent,
ResponseBuffers responseBuffers,
QueryResult<T> queryResult) |
void |
InternalStreamConnection.CommandEventSender.sendSucceededEvent(ResponseBuffers responseBuffers) |
private void |
InternalStreamConnection.updateSessionContext(SessionContext sessionContext,
ResponseBuffers responseBuffers) |
Modifier and Type | Method and Description |
---|---|
void |
InternalConnection.receiveMessageAsync(int responseTo,
SingleResultCallback<ResponseBuffers> callback)
Asynchronously receive a response to a sent message from the server.
|
void |
DefaultConnectionPool.PooledConnection.receiveMessageAsync(int responseTo,
SingleResultCallback<ResponseBuffers> callback) |
void |
InternalStreamConnection.receiveMessageAsync(int responseTo,
SingleResultCallback<ResponseBuffers> callback) |
void |
UsageTrackingInternalConnection.receiveMessageAsync(int responseTo,
SingleResultCallback<ResponseBuffers> callback) |
Constructor and Description |
---|
ReplyMessage(ResponseBuffers responseBuffers,
Decoder<T> decoder,
long requestId) |
Constructor and Description |
---|
MessageHeaderCallback(SingleResultCallback<ResponseBuffers> callback) |
SendMessageCallback(InternalConnection connection,
OutputBuffer buffer,
RequestMessage message,
int requestId,
java.lang.String commandName,
long startTimeNanos,
CommandListener commandListener,
SingleResultCallback<T> callback,
SingleResultCallback<ResponseBuffers> receiveMessageCallback) |
SendMessageCallback(InternalConnection connection,
OutputBuffer buffer,
RequestMessage message,
java.lang.String commandName,
long startTimeNanos,
CommandListener commandListener,
SingleResultCallback<T> callback,
SingleResultCallback<ResponseBuffers> receiveMessageCallback) |