com.mongodb.connection

Interface AsyncConnection

All Superinterfaces:

ReferenceCounted

All Known Implementing Classes:

DefaultServerConnection

Deprecated.

@ThreadSafe
 @Deprecated
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 and Description
<T> void	commandAsync(java.lang.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(java.lang.String database, BsonDocument command, FieldNameValidator commandFieldNameValidator, ReadPreference readPreference, Decoder<T> commandResultDecoder, SessionContext sessionContext, boolean responseExpected, SplittablePayload payload, FieldNameValidator payloadFieldNameValidator, SingleResultCallback<T> callback) Deprecated. Executes the command, consuming as much of the SplittablePayload as possible.
<T> void	commandAsync(java.lang.String database, BsonDocument command, FieldNameValidator fieldNameValidator, ReadPreference readPreference, Decoder<T> commandResultDecoder, SessionContext sessionContext, SingleResultCallback<T> callback) Deprecated. Execute the command.
void	deleteAsync(MongoNamespace namespace, boolean ordered, DeleteRequest deleteRequest, SingleResultCallback<WriteConcernResult> callback) Deprecated. Delete the documents using the delete wire protocol and apply the write concern asynchronously.
ConnectionDescription	getDescription() Deprecated. Gets the description of the connection.
<T> void	getMoreAsync(MongoNamespace namespace, long cursorId, int numberToReturn, Decoder<T> resultDecoder, SingleResultCallback<QueryResult<T>> callback) Deprecated. Get more result documents from a cursor asynchronously.
void	insertAsync(MongoNamespace namespace, boolean ordered, InsertRequest insertRequest, SingleResultCallback<WriteConcernResult> callback) Deprecated. Insert the documents using the insert wire protocol and apply the write concern asynchronously.
void	killCursorAsync(java.util.List<java.lang.Long> cursors, SingleResultCallback<java.lang.Void> callback) Deprecated. Replaced by killCursorAsync(MongoNamespace, List, SingleResultCallback)
void	killCursorAsync(MongoNamespace namespace, java.util.List<java.lang.Long> cursors, SingleResultCallback<java.lang.Void> callback) Deprecated. Asynchronously Kills the given list of cursors.
<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) Deprecated. Execute the query asynchronously.
AsyncConnection	retain() Deprecated. Retain an additional reference to this object.
void	updateAsync(MongoNamespace namespace, boolean ordered, UpdateRequest updateRequest, SingleResultCallback<WriteConcernResult> callback) Deprecated. 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()

Deprecated.

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()

Deprecated.

Gets the description of the connection.

Returns:

the connection description

insertAsync

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

Deprecated.

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)

Deprecated.

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)

Deprecated.

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(java.lang.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(java.lang.String database,
                      BsonDocument command,
                      FieldNameValidator fieldNameValidator,
                      ReadPreference readPreference,
                      Decoder<T> commandResultDecoder,
                      SessionContext sessionContext,
                      SingleResultCallback<T> callback)

Deprecated.

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(java.lang.String database,
                      BsonDocument command,
                      FieldNameValidator commandFieldNameValidator,
                      ReadPreference readPreference,
                      Decoder<T> commandResultDecoder,
                      SessionContext sessionContext,
                      boolean responseExpected,
                      SplittablePayload payload,
                      FieldNameValidator payloadFieldNameValidator,
                      SingleResultCallback<T> callback)

Deprecated.

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)

Deprecated.

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)

Deprecated.

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(java.util.List<java.lang.Long> cursors,
                                 SingleResultCallback<java.lang.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,
                     java.util.List<java.lang.Long> cursors,
                     SingleResultCallback<java.lang.Void> callback)

Deprecated.

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