Package com.mongodb.connection

Interface AsyncConnection

All Superinterfaces:

ReferenceCounted

@ThreadSafe
public interface AsyncConnection
extends ReferenceCounted

An asynchronous connection to a MongoDB server with non-blocking operations.

Implementations of this class are thread safe.

This interface is not stable. While methods will not be removed, new ones may be added.

Since:

3.0

Method Summary

Modifier and Type	Method	Description
<T> void	commandAsync(String database, BsonDocument command, boolean slaveOk, FieldNameValidator fieldNameValidator, Decoder<T> commandResultDecoder, SingleResultCallback<T> callback)	Deprecated. Prefer commandAsync(String, BsonDocument, FieldNameValidator, ReadPreference, Decoder, SessionContext, SingleResultCallback)
<T> void	commandAsync(String database, BsonDocument command, FieldNameValidator commandFieldNameValidator, ReadPreference readPreference, Decoder<T> commandResultDecoder, SessionContext sessionContext, boolean responseExpected, SplittablePayload payload, FieldNameValidator payloadFieldNameValidator, SingleResultCallback<T> callback)	Executes the command, consuming as much of the SplittablePayload as possible.
<T> void	commandAsync(String database, BsonDocument command, FieldNameValidator fieldNameValidator, ReadPreference readPreference, Decoder<T> commandResultDecoder, SessionContext sessionContext, SingleResultCallback<T> callback)	Execute the command.
void	deleteAsync(MongoNamespace namespace, boolean ordered, DeleteRequest deleteRequest, SingleResultCallback<WriteConcernResult> callback)	Delete the documents using the delete wire protocol and apply the write concern asynchronously.
ConnectionDescription	getDescription()	Gets the description of the connection.
<T> void	getMoreAsync(MongoNamespace namespace, long cursorId, int numberToReturn, Decoder<T> resultDecoder, SingleResultCallback<QueryResult<T>> callback)	Get more result documents from a cursor asynchronously.
void	insertAsync(MongoNamespace namespace, boolean ordered, InsertRequest insertRequest, SingleResultCallback<WriteConcernResult> callback)	Insert the documents using the insert wire protocol and apply the write concern asynchronously.
void	killCursorAsync(MongoNamespace namespace, List<Long> cursors, SingleResultCallback<Void> callback)	Asynchronously Kills the given list of cursors.
void	killCursorAsync(List<Long> cursors, SingleResultCallback<Void> callback)	Deprecated. Replaced by killCursorAsync(MongoNamespace, List, SingleResultCallback)
<T> void	queryAsync(MongoNamespace namespace, BsonDocument queryDocument, BsonDocument fields, int numberToReturn, int skip, boolean slaveOk, boolean tailableCursor, boolean awaitData, boolean noCursorTimeout, boolean partial, boolean oplogReplay, Decoder<T> resultDecoder, SingleResultCallback<QueryResult<T>> callback)	Deprecated. Replaced by queryAsync(MongoNamespace, BsonDocument, BsonDocument, int, int, int, boolean, boolean, boolean, boolean, boolean, boolean, Decoder, SingleResultCallback)
<T> void	queryAsync(MongoNamespace namespace, BsonDocument queryDocument, BsonDocument fields, int skip, int limit, int batchSize, boolean slaveOk, boolean tailableCursor, boolean awaitData, boolean noCursorTimeout, boolean partial, boolean oplogReplay, Decoder<T> resultDecoder, SingleResultCallback<QueryResult<T>> callback)	Execute the query asynchronously.
AsyncConnection	retain()	Retain an additional reference to this object.
void	updateAsync(MongoNamespace namespace, boolean ordered, UpdateRequest updateRequest, SingleResultCallback<WriteConcernResult> callback)	Update the documents using the update wire protocol and apply the write concern asynchronously.

Methods inherited from interface com.mongodb.binding.ReferenceCounted

getCount, release

Method Detail

retain

AsyncConnection retain()

Description copied from interface: ReferenceCounted

Retain an additional reference to this object. All retained references must be released, or there will be a leak.

Specified by:

retain in interface ReferenceCounted

Returns:

this

getDescription

ConnectionDescription getDescription()

Gets the description of the connection.

Returns:

the connection description

insertAsync

void insertAsync(MongoNamespace namespace,
                 boolean ordered,
                 InsertRequest insertRequest,
                 SingleResultCallback<WriteConcernResult> callback)

Insert the documents using the insert wire protocol and apply the write concern asynchronously.

Parameters:

namespace - the namespace

ordered - whether the writes are ordered

insertRequest - the insert request

callback - the callback to be passed the write result

updateAsync

void updateAsync(MongoNamespace namespace,
                 boolean ordered,
                 UpdateRequest updateRequest,
                 SingleResultCallback<WriteConcernResult> callback)

Update the documents using the update wire protocol and apply the write concern asynchronously.

Parameters:

namespace - the namespace

ordered - whether the writes are ordered

updateRequest - the update request

callback - the callback to be passed the write result

deleteAsync

void deleteAsync(MongoNamespace namespace,
                 boolean ordered,
                 DeleteRequest deleteRequest,
                 SingleResultCallback<WriteConcernResult> callback)

Delete the documents using the delete wire protocol and apply the write concern asynchronously.

Parameters:

namespace - the namespace

ordered - whether the writes are ordered

deleteRequest - the delete request

callback - the callback to be passed the write result

commandAsync

@Deprecated
<T> void commandAsync(String database,
                      BsonDocument command,
                      boolean slaveOk,
                      FieldNameValidator fieldNameValidator,
                      Decoder<T> commandResultDecoder,
                      SingleResultCallback<T> callback)

Deprecated. Prefer commandAsync(String, BsonDocument, FieldNameValidator, ReadPreference, Decoder, SessionContext, SingleResultCallback)

Execute the command asynchronously.

Type Parameters:

T - the type of the result

Parameters:

database - the database to execute the command in

command - the command document

slaveOk - whether the command can run on a secondary

fieldNameValidator - the field name validator for the command document

commandResultDecoder - the decoder for the result

callback - the callback to be passed the command result

commandAsync

<T> void commandAsync(String database,
                      BsonDocument command,
                      FieldNameValidator fieldNameValidator,
                      ReadPreference readPreference,
                      Decoder<T> commandResultDecoder,
                      SessionContext sessionContext,
                      SingleResultCallback<T> callback)

Execute the command.

Type Parameters:

T - the type of the result

Parameters:

database - the database to execute the command in

command - the command document

fieldNameValidator - the field name validator for the command document

readPreference - the read preference that was applied to get this connection, or null if this is a write operation

commandResultDecoder - the decoder for the result

sessionContext - the session context

callback - the callback to be passed the write result

Since:

3.6

commandAsync

<T> void commandAsync(String database,
                      BsonDocument command,
                      FieldNameValidator commandFieldNameValidator,
                      ReadPreference readPreference,
                      Decoder<T> commandResultDecoder,
                      SessionContext sessionContext,
                      boolean responseExpected,
                      SplittablePayload payload,
                      FieldNameValidator payloadFieldNameValidator,
                      SingleResultCallback<T> callback)

Executes the command, consuming as much of the SplittablePayload as possible.

Type Parameters:

T - the type of the result

Parameters:

database - the database to execute the command in

command - the command document

commandFieldNameValidator - the field name validator for the command document

readPreference - the read preference that was applied to get this connection, or null if this is a write operation

commandResultDecoder - the decoder for the result

sessionContext - the session context

responseExpected - true if a response from the server is expected

payload - the splittable payload to incorporate with the command

payloadFieldNameValidator - the field name validator for the payload documents

callback - the callback to be passed the write result

Since:

3.6

queryAsync

@Deprecated
<T> void queryAsync(MongoNamespace namespace,
                    BsonDocument queryDocument,
                    BsonDocument fields,
                    int numberToReturn,
                    int skip,
                    boolean slaveOk,
                    boolean tailableCursor,
                    boolean awaitData,
                    boolean noCursorTimeout,
                    boolean partial,
                    boolean oplogReplay,
                    Decoder<T> resultDecoder,
                    SingleResultCallback<QueryResult<T>> callback)

Deprecated. Replaced by queryAsync(MongoNamespace, BsonDocument, BsonDocument, int, int, int, boolean, boolean, boolean, boolean, boolean, boolean, Decoder, SingleResultCallback)

Execute the query asynchronously.

Type Parameters:

T - the query result document type

Parameters:

namespace - the namespace to query

queryDocument - the query document

fields - the field to include or exclude

numberToReturn - the number of documents to return

skip - the number of documents to skip

slaveOk - whether the query can run on a secondary

tailableCursor - whether to return a tailable cursor

awaitData - whether a tailable cursor should wait before returning if no documents are available

noCursorTimeout - whether the cursor should not timeout

partial - whether partial results from sharded clusters are acceptable

oplogReplay - whether to replay the oplog

resultDecoder - the decoder for the query result documents

callback - the callback to be passed the write result

queryAsync

<T> void queryAsync(MongoNamespace namespace,
                    BsonDocument queryDocument,
                    BsonDocument fields,
                    int skip,
                    int limit,
                    int batchSize,
                    boolean slaveOk,
                    boolean tailableCursor,
                    boolean awaitData,
                    boolean noCursorTimeout,
                    boolean partial,
                    boolean oplogReplay,
                    Decoder<T> resultDecoder,
                    SingleResultCallback<QueryResult<T>> callback)

Execute the query asynchronously.

Type Parameters:

T - the query result document type

Parameters:

namespace - the namespace to query

queryDocument - the query document

fields - the field to include or exclude

skip - the number of documents to skip

limit - the maximum number of documents to return in all batches

batchSize - the maximum number of documents to return in this batch

slaveOk - whether the query can run on a secondary

tailableCursor - whether to return a tailable cursor

awaitData - whether a tailable cursor should wait before returning if no documents are available

noCursorTimeout - whether the cursor should not timeout

partial - whether partial results from sharded clusters are acceptable

oplogReplay - whether to replay the oplog

resultDecoder - the decoder for the query result documents

callback - the callback to be passed the write result

Since:

3.1

getMoreAsync

<T> void getMoreAsync(MongoNamespace namespace,
                      long cursorId,
                      int numberToReturn,
                      Decoder<T> resultDecoder,
                      SingleResultCallback<QueryResult<T>> callback)

Get more result documents from a cursor asynchronously.

Type Parameters:

T - the type of the query result documents

Parameters:

namespace - the namespace to get more documents from

cursorId - the cursor id

numberToReturn - the number of documents to return

resultDecoder - the decoder for the query result documents

callback - the callback to be passed the query result

killCursorAsync

@Deprecated
void killCursorAsync(List<Long> cursors,
                     SingleResultCallback<Void> callback)

Deprecated. Replaced by killCursorAsync(MongoNamespace, List, SingleResultCallback)

Asynchronously Kills the given list of cursors.

Parameters:

cursors - the cursors

callback - the callback that is called once the cursors have been killed

killCursorAsync

void killCursorAsync(MongoNamespace namespace,
                     List<Long> cursors,
                     SingleResultCallback<Void> callback)

Asynchronously Kills the given list of cursors.

Parameters:

namespace - the namespace in which the cursors live

cursors - the cursors

callback - the callback that is called once the cursors have been killed