Interface AsyncConnection

  • All Superinterfaces:
    ReferenceCounted

    @ThreadSafe
    @Deprecated
    public interface AsyncConnection
    extends ReferenceCounted
    Deprecated.
    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 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

        <T> void commandAsync​(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​(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)
        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

        void killCursorAsync​(MongoNamespace namespace,
                             List<Long> cursors,
                             SingleResultCallback<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