com.mongodb.connection

Class DefaultServerConnection

java.lang.Object

com.mongodb.connection.AbstractReferenceCounted

com.mongodb.connection.DefaultServerConnection

All Implemented Interfaces:

ReferenceCounted, AsyncConnection, Connection

class DefaultServerConnection
extends AbstractReferenceCounted
implements Connection, AsyncConnection

Field Summary

Fields

Modifier and Type	Field and Description
private ClusterConnectionMode	clusterConnectionMode
private static Logger	LOGGER
private ProtocolExecutor	protocolExecutor
private InternalConnection	wrapped

Constructor Summary

Constructors

Constructor and Description
DefaultServerConnection(InternalConnection wrapped, ProtocolExecutor protocolExecutor, ClusterConnectionMode clusterConnectionMode)

Method Summary

Modifier and Type	Method and Description
<T> T	command(java.lang.String database, BsonDocument command, boolean slaveOk, FieldNameValidator fieldNameValidator, Decoder<T> commandResultDecoder) Execute the command.
<T> void	commandAsync(java.lang.String database, BsonDocument command, boolean slaveOk, FieldNameValidator fieldNameValidator, Decoder<T> commandResultDecoder, SingleResultCallback<T> callback) Execute the command asynchronously.
WriteConcernResult	delete(MongoNamespace namespace, boolean ordered, WriteConcern writeConcern, java.util.List<DeleteRequest> deletes) Delete the documents using the delete wire protocol and apply the write concern.
void	deleteAsync(MongoNamespace namespace, boolean ordered, WriteConcern writeConcern, java.util.List<DeleteRequest> deletes, SingleResultCallback<WriteConcernResult> callback) Delete the documents using the delete wire protocol and apply the write concern asynchronously.
BulkWriteResult	deleteCommand(MongoNamespace namespace, boolean ordered, WriteConcern writeConcern, java.util.List<DeleteRequest> deletes) Delete the documents using the delete command.
void	deleteCommandAsync(MongoNamespace namespace, boolean ordered, WriteConcern writeConcern, java.util.List<DeleteRequest> deletes, SingleResultCallback<BulkWriteResult> callback) Delete the documents using the delete command asynchronously.
private <T> T	executeProtocol(Protocol<T> protocol)
private <T> void	executeProtocolAsync(Protocol<T> protocol, SingleResultCallback<T> callback)
ConnectionDescription	getDescription() Gets the description of the connection.
<T> QueryResult<T>	getMore(MongoNamespace namespace, long cursorId, int numberToReturn, Decoder<T> resultDecoder) Get more result documents from a cursor.
<T> void	getMoreAsync(MongoNamespace namespace, long cursorId, int numberToReturn, Decoder<T> resultDecoder, SingleResultCallback<QueryResult<T>> callback) Get more result documents from a cursor asynchronously.
private boolean	getSlaveOk(boolean slaveOk)
WriteConcernResult	insert(MongoNamespace namespace, boolean ordered, WriteConcern writeConcern, java.util.List<InsertRequest> inserts) Insert the documents using the insert wire protocol and apply the write concern.
void	insertAsync(MongoNamespace namespace, boolean ordered, WriteConcern writeConcern, java.util.List<InsertRequest> inserts, SingleResultCallback<WriteConcernResult> callback) Insert the documents using the insert wire protocol and apply the write concern asynchronously.
BulkWriteResult	insertCommand(MongoNamespace namespace, boolean ordered, WriteConcern writeConcern, java.lang.Boolean bypassDocumentValidation, java.util.List<InsertRequest> inserts) Insert the documents using the insert command.
BulkWriteResult	insertCommand(MongoNamespace namespace, boolean ordered, WriteConcern writeConcern, java.util.List<InsertRequest> inserts) Insert the documents using the insert command.
void	insertCommandAsync(MongoNamespace namespace, boolean ordered, WriteConcern writeConcern, java.lang.Boolean bypassDocumentValidation, java.util.List<InsertRequest> inserts, SingleResultCallback<BulkWriteResult> callback) Insert the documents using the insert command asynchronously.
void	insertCommandAsync(MongoNamespace namespace, boolean ordered, WriteConcern writeConcern, java.util.List<InsertRequest> inserts, SingleResultCallback<BulkWriteResult> callback) Insert the documents using the insert command asynchronously.
void	killCursor(java.util.List<java.lang.Long> cursors) Kills the given list of cursors.
void	killCursor(MongoNamespace namespace, java.util.List<java.lang.Long> cursors) Kills the given list of cursors.
void	killCursorAsync(java.util.List<java.lang.Long> cursors, SingleResultCallback<java.lang.Void> callback) Asynchronously Kills the given list of cursors.
void	killCursorAsync(MongoNamespace namespace, java.util.List<java.lang.Long> cursors, SingleResultCallback<java.lang.Void> callback) Asynchronously Kills the given list of cursors.
<T> QueryResult<T>	query(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) Execute the query.
<T> QueryResult<T>	query(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) Execute the query.
<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) Execute the query asynchronously.
<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.
void	release() Release a reference to this object.
DefaultServerConnection	retain() Retain an additional reference to this object.
WriteConcernResult	update(MongoNamespace namespace, boolean ordered, WriteConcern writeConcern, java.util.List<UpdateRequest> updates) Update the documents using the update wire protocol and apply the write concern.
void	updateAsync(MongoNamespace namespace, boolean ordered, WriteConcern writeConcern, java.util.List<UpdateRequest> updates, SingleResultCallback<WriteConcernResult> callback) Update the documents using the update wire protocol and apply the write concern asynchronously.
BulkWriteResult	updateCommand(MongoNamespace namespace, boolean ordered, WriteConcern writeConcern, java.lang.Boolean bypassDocumentValidation, java.util.List<UpdateRequest> updates) Update the documents using the update command.
BulkWriteResult	updateCommand(MongoNamespace namespace, boolean ordered, WriteConcern writeConcern, java.util.List<UpdateRequest> updates) Update the documents using the update command.
void	updateCommandAsync(MongoNamespace namespace, boolean ordered, WriteConcern writeConcern, java.lang.Boolean bypassDocumentValidation, java.util.List<UpdateRequest> updates, SingleResultCallback<BulkWriteResult> callback) Update the documents using the update command asynchronously.
void	updateCommandAsync(MongoNamespace namespace, boolean ordered, WriteConcern writeConcern, java.util.List<UpdateRequest> updates, SingleResultCallback<BulkWriteResult> callback) Update the documents using the update command asynchronously.

Methods inherited from class com.mongodb.connection.AbstractReferenceCounted

getCount

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.mongodb.binding.ReferenceCounted

getCount

Field Detail

LOGGER

private static final Logger LOGGER

wrapped

private final InternalConnection wrapped

protocolExecutor

private final ProtocolExecutor protocolExecutor

clusterConnectionMode

private final ClusterConnectionMode clusterConnectionMode

Constructor Detail

DefaultServerConnection

public DefaultServerConnection(InternalConnection wrapped,
                               ProtocolExecutor protocolExecutor,
                               ClusterConnectionMode clusterConnectionMode)

Method Detail

retain

public DefaultServerConnection 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

Specified by:

retain in interface AsyncConnection

Specified by:

retain in interface Connection

Overrides:

retain in class AbstractReferenceCounted

Returns:

this

release

public void release()

Description copied from interface: ReferenceCounted

Release a reference to this object.

Specified by:

release in interface ReferenceCounted

Overrides:

release in class AbstractReferenceCounted

getDescription

public ConnectionDescription getDescription()

Description copied from interface: Connection

Gets the description of the connection.

Specified by:

getDescription in interface AsyncConnection

Specified by:

getDescription in interface Connection

Returns:

the connection description

insert

public WriteConcernResult insert(MongoNamespace namespace,
                                 boolean ordered,
                                 WriteConcern writeConcern,
                                 java.util.List<InsertRequest> inserts)

Description copied from interface: Connection

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

Specified by:

insert in interface Connection

Parameters:

namespace - the namespace

ordered - whether the writes are ordered

writeConcern - the write concern

inserts - the inserts

Returns:

the write concern result

insertAsync

public void insertAsync(MongoNamespace namespace,
                        boolean ordered,
                        WriteConcern writeConcern,
                        java.util.List<InsertRequest> inserts,
                        SingleResultCallback<WriteConcernResult> callback)

Description copied from interface: AsyncConnection

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

Specified by:

insertAsync in interface AsyncConnection

Parameters:

namespace - the namespace

ordered - whether the writes are ordered

writeConcern - the write concern

inserts - the inserts

callback - the callback to be passed the write result

update

public WriteConcernResult update(MongoNamespace namespace,
                                 boolean ordered,
                                 WriteConcern writeConcern,
                                 java.util.List<UpdateRequest> updates)

Description copied from interface: Connection

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

Specified by:

update in interface Connection

Parameters:

namespace - the namespace

ordered - whether the writes are ordered

writeConcern - the write concern

updates - the updates

Returns:

the write concern result

updateAsync

public void updateAsync(MongoNamespace namespace,
                        boolean ordered,
                        WriteConcern writeConcern,
                        java.util.List<UpdateRequest> updates,
                        SingleResultCallback<WriteConcernResult> callback)

Description copied from interface: AsyncConnection

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

Specified by:

updateAsync in interface AsyncConnection

Parameters:

namespace - the namespace

ordered - whether the writes are ordered

writeConcern - the write concern

updates - the updates

callback - the callback to be passed the write result

delete

public WriteConcernResult delete(MongoNamespace namespace,
                                 boolean ordered,
                                 WriteConcern writeConcern,
                                 java.util.List<DeleteRequest> deletes)

Description copied from interface: Connection

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

Specified by:

delete in interface Connection

Parameters:

namespace - the namespace

ordered - whether the writes are ordered

writeConcern - the write concern

deletes - the deletes

Returns:

the write concern result

deleteAsync

public void deleteAsync(MongoNamespace namespace,
                        boolean ordered,
                        WriteConcern writeConcern,
                        java.util.List<DeleteRequest> deletes,
                        SingleResultCallback<WriteConcernResult> callback)

Description copied from interface: AsyncConnection

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

Specified by:

deleteAsync in interface AsyncConnection

Parameters:

namespace - the namespace

ordered - whether the writes are ordered

writeConcern - the write concern

deletes - the deletes

callback - the callback to be passed the write result

insertCommand

public BulkWriteResult insertCommand(MongoNamespace namespace,
                                     boolean ordered,
                                     WriteConcern writeConcern,
                                     java.util.List<InsertRequest> inserts)

Description copied from interface: Connection

Insert the documents using the insert command.

Specified by:

insertCommand in interface Connection

Parameters:

namespace - the namespace

ordered - whether the writes are ordered

writeConcern - the write concern

inserts - the inserts

Returns:

the bulk write result

insertCommand

public BulkWriteResult insertCommand(MongoNamespace namespace,
                                     boolean ordered,
                                     WriteConcern writeConcern,
                                     java.lang.Boolean bypassDocumentValidation,
                                     java.util.List<InsertRequest> inserts)

Description copied from interface: Connection

Insert the documents using the insert command.

Specified by:

insertCommand in interface Connection

Parameters:

namespace - the namespace

ordered - whether the writes are ordered

writeConcern - the write concern

bypassDocumentValidation - the bypassDocumentValidation flag

inserts - the inserts

Returns:

the bulk write result

insertCommandAsync

public void insertCommandAsync(MongoNamespace namespace,
                               boolean ordered,
                               WriteConcern writeConcern,
                               java.util.List<InsertRequest> inserts,
                               SingleResultCallback<BulkWriteResult> callback)

Description copied from interface: AsyncConnection

Insert the documents using the insert command asynchronously.

Specified by:

insertCommandAsync in interface AsyncConnection

Parameters:

namespace - the namespace

ordered - whether the writes are ordered

writeConcern - the write concern

inserts - the inserts

callback - the callback to be passed the bulk write result

insertCommandAsync

public void insertCommandAsync(MongoNamespace namespace,
                               boolean ordered,
                               WriteConcern writeConcern,
                               java.lang.Boolean bypassDocumentValidation,
                               java.util.List<InsertRequest> inserts,
                               SingleResultCallback<BulkWriteResult> callback)

Description copied from interface: AsyncConnection

Insert the documents using the insert command asynchronously.

Specified by:

insertCommandAsync in interface AsyncConnection

Parameters:

namespace - the namespace

ordered - whether the writes are ordered

writeConcern - the write concern

bypassDocumentValidation - the bypassDocumentValidation flag

inserts - the inserts

callback - the callback to be passed the bulk write result

updateCommand

public BulkWriteResult updateCommand(MongoNamespace namespace,
                                     boolean ordered,
                                     WriteConcern writeConcern,
                                     java.util.List<UpdateRequest> updates)

Description copied from interface: Connection

Update the documents using the update command.

Specified by:

updateCommand in interface Connection

Parameters:

namespace - the namespace

ordered - whether the writes are ordered

writeConcern - the write concern

updates - the updates

Returns:

the bulk write result

updateCommand

public BulkWriteResult updateCommand(MongoNamespace namespace,
                                     boolean ordered,
                                     WriteConcern writeConcern,
                                     java.lang.Boolean bypassDocumentValidation,
                                     java.util.List<UpdateRequest> updates)

Description copied from interface: Connection

Update the documents using the update command.

Specified by:

updateCommand in interface Connection

Parameters:

namespace - the namespace

ordered - whether the writes are ordered

writeConcern - the write concern

bypassDocumentValidation - the bypassDocumentValidation flag

updates - the updates

Returns:

the bulk write result

updateCommandAsync

public void updateCommandAsync(MongoNamespace namespace,
                               boolean ordered,
                               WriteConcern writeConcern,
                               java.util.List<UpdateRequest> updates,
                               SingleResultCallback<BulkWriteResult> callback)

Description copied from interface: AsyncConnection

Update the documents using the update command asynchronously.

Specified by:

updateCommandAsync in interface AsyncConnection

Parameters:

namespace - the namespace

ordered - whether the writes are ordered

writeConcern - the write concern

updates - the updates

callback - the callback to be passed the BulkWriteResult

updateCommandAsync

public void updateCommandAsync(MongoNamespace namespace,
                               boolean ordered,
                               WriteConcern writeConcern,
                               java.lang.Boolean bypassDocumentValidation,
                               java.util.List<UpdateRequest> updates,
                               SingleResultCallback<BulkWriteResult> callback)

Description copied from interface: AsyncConnection

Update the documents using the update command asynchronously.

Specified by:

updateCommandAsync in interface AsyncConnection

Parameters:

namespace - the namespace

ordered - whether the writes are ordered

writeConcern - the write concern

bypassDocumentValidation - the bypassDocumentValidation flag

updates - the updates

callback - the callback to be passed the BulkWriteResult

deleteCommand

public BulkWriteResult deleteCommand(MongoNamespace namespace,
                                     boolean ordered,
                                     WriteConcern writeConcern,
                                     java.util.List<DeleteRequest> deletes)

Description copied from interface: Connection

Delete the documents using the delete command.

Specified by:

deleteCommand in interface Connection

Parameters:

namespace - the namespace

ordered - whether the writes are ordered

writeConcern - the write concern

deletes - the deletes

Returns:

the bulk write result

deleteCommandAsync

public void deleteCommandAsync(MongoNamespace namespace,
                               boolean ordered,
                               WriteConcern writeConcern,
                               java.util.List<DeleteRequest> deletes,
                               SingleResultCallback<BulkWriteResult> callback)

Description copied from interface: AsyncConnection

Delete the documents using the delete command asynchronously.

Specified by:

deleteCommandAsync in interface AsyncConnection

Parameters:

namespace - the namespace

ordered - whether the writes are ordered

writeConcern - the write concern

deletes - the deletes

callback - the callback to be passed the BulkWriteResult

command

public <T> T command(java.lang.String database,
                     BsonDocument command,
                     boolean slaveOk,
                     FieldNameValidator fieldNameValidator,
                     Decoder<T> commandResultDecoder)

Description copied from interface: Connection

Execute the command.

Specified by:

command in interface Connection

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

Returns:

the command result

commandAsync

public <T> void commandAsync(java.lang.String database,
                             BsonDocument command,
                             boolean slaveOk,
                             FieldNameValidator fieldNameValidator,
                             Decoder<T> commandResultDecoder,
                             SingleResultCallback<T> callback)

Description copied from interface: AsyncConnection

Execute the command asynchronously.

Specified by:

commandAsync in interface AsyncConnection

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

query

public <T> QueryResult<T> query(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)

Description copied from interface: Connection

Execute the query.

Specified by:

query in interface Connection

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

Returns:

the query results

query

public <T> QueryResult<T> query(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)

Description copied from interface: Connection

Execute the query.

Specified by:

query in interface Connection

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

Returns:

the query results

queryAsync

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

Description copied from interface: AsyncConnection

Execute the query asynchronously.

Specified by:

queryAsync in interface AsyncConnection

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

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

Description copied from interface: AsyncConnection

Execute the query asynchronously.

Specified by:

queryAsync in interface AsyncConnection

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

getMore

public <T> QueryResult<T> getMore(MongoNamespace namespace,
                                  long cursorId,
                                  int numberToReturn,
                                  Decoder<T> resultDecoder)

Description copied from interface: Connection

Get more result documents from a cursor.

Specified by:

getMore in interface Connection

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 results

Returns:

the query results

getMoreAsync

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

Description copied from interface: AsyncConnection

Get more result documents from a cursor asynchronously.

Specified by:

getMoreAsync in interface AsyncConnection

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

killCursor

public void killCursor(java.util.List<java.lang.Long> cursors)

Description copied from interface: Connection

Kills the given list of cursors.

Specified by:

killCursor in interface Connection

Parameters:

cursors - the cursors

killCursor

public void killCursor(MongoNamespace namespace,
                       java.util.List<java.lang.Long> cursors)

Description copied from interface: Connection

Kills the given list of cursors.

Specified by:

killCursor in interface Connection

Parameters:

namespace - the namespace to in which the cursors live

cursors - the cursors

killCursorAsync

public void killCursorAsync(java.util.List<java.lang.Long> cursors,
                            SingleResultCallback<java.lang.Void> callback)

Description copied from interface: AsyncConnection

Asynchronously Kills the given list of cursors.

Specified by:

killCursorAsync in interface AsyncConnection

Parameters:

cursors - the cursors

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

killCursorAsync

public void killCursorAsync(MongoNamespace namespace,
                            java.util.List<java.lang.Long> cursors,
                            SingleResultCallback<java.lang.Void> callback)

Description copied from interface: AsyncConnection

Asynchronously Kills the given list of cursors.

Specified by:

killCursorAsync in interface AsyncConnection

Parameters:

namespace - the namespace in which the cursors live

cursors - the cursors

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

getSlaveOk

private boolean getSlaveOk(boolean slaveOk)

executeProtocol

private <T> T executeProtocol(Protocol<T> protocol)

executeProtocolAsync

private <T> void executeProtocolAsync(Protocol<T> protocol,
                                      SingleResultCallback<T> callback)