Uses of Interface
com.allanbank.mongodb.Callback

Packages that use Callback

Package	Description
com.allanbank.mongodb	Provides a Java driver for the MongoDB document store that allows asynchronous invocation of requests.
com.allanbank.mongodb.client	Provides implementations of the main client interfaces and classes to translate the Reply(s) from the server.
com.allanbank.mongodb.connection	Provides interfaces for managing connections to different MongoDB server configurations.
com.allanbank.mongodb.connection.auth	Wraps a connection and ensures that all requests are properly authenticated.
com.allanbank.mongodb.connection.message	Low level messages to be sent to the MongoDB server.
com.allanbank.mongodb.connection.proxy	Support for connection that delegate to a lower level connection.
com.allanbank.mongodb.connection.rs	Support for connections to Replica Sets.
com.allanbank.mongodb.connection.socket	Low level socket connection to a single MongoDB server.
com.allanbank.mongodb.connection.state	Support for tracking the state of a set of MongoDB servers.

Uses of Callback in com.allanbank.mongodb

Subinterfaces of Callback in com.allanbank.mongodb

Modifier and Type	Interface and Description
interface	StreamCallback<V> Extension of the Callback interface to provide the ability to notify callers when the stream is done.

Methods in com.allanbank.mongodb with parameters of type Callback

Modifier and Type	Method and Description
void	MongoCollection.aggregateAsync(Callback<List<Document>> results, Aggregate.Builder command) Invokes a aggregate command on the server.
void	MongoCollection.aggregateAsync(Callback<List<Document>> results, Aggregate command) Invokes a aggregate command on the server.
void	MongoCollection.countAsync(Callback<Long> results) Counts the set of documents in the collection.
void	MongoCollection.countAsync(Callback<Long> results, DocumentAssignable query) Counts the set of documents matching the query document in the collection.
void	MongoCollection.countAsync(Callback<Long> results, DocumentAssignable query, ReadPreference readPreference) Counts the set of documents matching the query document in the collection.
void	MongoCollection.countAsync(Callback<Long> results, ReadPreference readPreference) Counts the set of documents in the collection.
void	MongoCollection.deleteAsync(Callback<Long> results, DocumentAssignable query) Deletes a set of documents matching a query from the collection.
void	MongoCollection.deleteAsync(Callback<Long> results, DocumentAssignable query, boolean singleDelete) Deletes a set of documents matching a query from the collection.
void	MongoCollection.deleteAsync(Callback<Long> results, DocumentAssignable query, boolean singleDelete, Durability durability) Deletes a set of documents matching a query from the collection.
void	MongoCollection.deleteAsync(Callback<Long> results, DocumentAssignable query, Durability durability) Deletes a set of documents matching a query from the collection.
void	MongoCollection.distinctAsync(Callback<ArrayElement> results, Distinct.Builder command) Invokes a distinct command on the server.
void	MongoCollection.distinctAsync(Callback<ArrayElement> results, Distinct command) Invokes a distinct command on the server.
void	MongoCollection.explainAsync(Callback<Document> results, Find.Builder query) Explains the way that the document will be performed.
void	MongoCollection.explainAsync(Callback<Document> results, Find query) Explains the way that the document will be performed.
void	MongoCollection.findAndModifyAsync(Callback<Document> results, FindAndModify.Builder command) Invokes a findAndModify command on the server.
void	MongoCollection.findAndModifyAsync(Callback<Document> results, FindAndModify command) Invokes a findAndModify command on the server.
void	MongoCollection.findAsync(Callback<MongoIterator<Document>> results, DocumentAssignable query) Finds the set of documents matching the query document in the collection.
void	MongoCollection.findAsync(Callback<MongoIterator<Document>> results, Find.Builder query) Finds the set of documents matching the query in the collection.
void	MongoCollection.findAsync(Callback<MongoIterator<Document>> results, Find query) Finds the set of documents matching the query in the collection.
void	MongoCollection.findOneAsync(Callback<Document> results, DocumentAssignable query) Finds a single matching document in the collection.
void	MongoCollection.findOneAsync(Callback<Document> results, Find.Builder query) Finds a single matching document in the collection.
void	MongoCollection.findOneAsync(Callback<Document> results, Find query) Finds a single matching document in the collection.
void	MongoCollection.groupByAsync(Callback<ArrayElement> results, GroupBy.Builder command) Invokes a group command on the server.
void	MongoCollection.groupByAsync(Callback<ArrayElement> results, GroupBy command) Invokes a group command on the server.
void	MongoCollection.insertAsync(Callback<Integer> results, boolean continueOnError, DocumentAssignable... documents) Inserts a set of documents into the collection.
void	MongoCollection.insertAsync(Callback<Integer> results, boolean continueOnError, Durability durability, DocumentAssignable... documents) Inserts a set of documents into the collection.
void	MongoCollection.insertAsync(Callback<Integer> results, DocumentAssignable... documents) Inserts a set of documents into the collection.
void	MongoCollection.insertAsync(Callback<Integer> results, Durability durability, DocumentAssignable... documents) Inserts a set of documents into the collection.
void	MongoCollection.mapReduceAsync(Callback<List<Document>> results, MapReduce.Builder command) Invokes a mapReduce command on the server.
void	MongoCollection.mapReduceAsync(Callback<List<Document>> results, MapReduce command) Invokes a mapReduce command on the server.
void	MongoDatabase.runCommandAsync(Callback<Document> reply, String command) Runs a command against the database.
void	MongoDatabase.runCommandAsync(Callback<Document> reply, String command, DocumentAssignable options) Runs a command against the database.
void	MongoDatabase.runCommandAsync(Callback<Document> reply, String commandName, int commandValue, DocumentAssignable options) Runs a command against the database.
void	MongoDatabase.runCommandAsync(Callback<Document> reply, String commandName, String commandValue, DocumentAssignable options) Runs a command against the database.
void	MongoCollection.saveAsync(Callback<Integer> results, DocumentAssignable document) Saves the document to the collection.
void	MongoCollection.saveAsync(Callback<Integer> results, DocumentAssignable document, Durability durability) Saves the document to the collection.
MongoCursorControl	MongoCollection.streamingFind(Callback<Document> results, DocumentAssignable query) Deprecated. Use the MongoCollection.streamingFind(StreamCallback, DocumentAssignable) method instead. This method will be removed after the 1.3.0 release.
MongoCursorControl	MongoCollection.streamingFind(Callback<Document> results, Find query) Deprecated. Use the MongoCollection.streamingFind(StreamCallback, Find) method instead. This method will be removed after the 1.3.0 release.
void	MongoCollection.textSearchAsync(Callback<List<TextResult>> results, Text.Builder command) Invokes a text command on the server.
void	MongoCollection.textSearchAsync(Callback<List<TextResult>> results, Text command) Invokes a text command on the server.
void	MongoCollection.updateAsync(Callback<Long> results, DocumentAssignable query, DocumentAssignable update) Applies updates to a set of documents within the collection.
void	MongoCollection.updateAsync(Callback<Long> results, DocumentAssignable query, DocumentAssignable update, boolean multiUpdate, boolean upsert) Applies updates to a set of documents within the collection.
void	MongoCollection.updateAsync(Callback<Long> results, DocumentAssignable query, DocumentAssignable update, boolean multiUpdate, boolean upsert, Durability durability) Applies updates to a set of documents within the collection.
void	MongoCollection.updateAsync(Callback<Long> results, DocumentAssignable query, DocumentAssignable update, Durability durability) Applies updates to a set of documents within the collection.

Uses of Callback in com.allanbank.mongodb.client

Classes in com.allanbank.mongodb.client that implement Callback

Modifier and Type	Class and Description
class	AbstractReplyCallback<F> Helper class for constructing callbacks that convert a Reply message into a different type of result.
class	AbstractValidatingReplyCallback Helper class for constructing callbacks that convert a Reply message into a different type of result.
class	LongToIntCallback LongToIntCallback provides a simple callback wrapper to convert the long value to an integer.
class	ReplyResultCallback Callback to extract the map/reduce and aggregation results from the reply.
class	TextCallback TextCallback provides conversion from a text command's result document to a TextResult.

Methods in com.allanbank.mongodb.client that return Callback

Modifier and Type	Method and Description
Callback<F>	AbstractReplyCallback.getForwardCallback() Returns the forwardCallback value.

Methods in com.allanbank.mongodb.client with parameters of type Callback

Modifier and Type	Method and Description
void	AbstractMongoCollection.aggregateAsync(Callback<List<Document>> results, Aggregate.Builder command) Invokes a aggregate command on the server.
abstract void	AbstractMongoCollection.aggregateAsync(Callback<List<Document>> results, Aggregate command) Invokes a aggregate command on the server.
void	MongoCollectionImpl.aggregateAsync(Callback<List<Document>> results, Aggregate command) Invokes a aggregate command on the server.
void	AbstractMongoCollection.countAsync(Callback<Long> results) Counts the set of documents in the collection.
void	AbstractMongoCollection.countAsync(Callback<Long> results, DocumentAssignable query) Counts the set of documents matching the query document in the collection.
abstract void	AbstractMongoCollection.countAsync(Callback<Long> results, DocumentAssignable query, ReadPreference readPreference) Counts the set of documents matching the query document in the collection.
void	MongoCollectionImpl.countAsync(Callback<Long> results, DocumentAssignable query, ReadPreference readPreference) Counts the set of documents matching the query document in the collection.
void	AbstractMongoCollection.countAsync(Callback<Long> results, ReadPreference readPreference) Counts the set of documents in the collection.
void	AbstractMongoCollection.deleteAsync(Callback<Long> results, DocumentAssignable query) Deletes a set of documents matching a query from the collection.
void	AbstractMongoCollection.deleteAsync(Callback<Long> results, DocumentAssignable query, boolean singleDelete) Deletes a set of documents matching a query from the collection.
abstract void	AbstractMongoCollection.deleteAsync(Callback<Long> results, DocumentAssignable query, boolean singleDelete, Durability durability) Deletes a set of documents matching a query from the collection.
void	MongoCollectionImpl.deleteAsync(Callback<Long> results, DocumentAssignable query, boolean singleDelete, Durability durability) Deletes a set of documents matching a query from the collection.
void	AbstractMongoCollection.deleteAsync(Callback<Long> results, DocumentAssignable query, Durability durability) Deletes a set of documents matching a query from the collection.
void	AbstractMongoCollection.distinctAsync(Callback<ArrayElement> results, Distinct.Builder command) Invokes a distinct command on the server.
abstract void	AbstractMongoCollection.distinctAsync(Callback<ArrayElement> results, Distinct command) Invokes a distinct command on the server.
void	MongoCollectionImpl.distinctAsync(Callback<ArrayElement> results, Distinct command) Invokes a distinct command on the server.
void	AbstractMongoCollection.explainAsync(Callback<Document> results, Find.Builder query) Explains the way that the document will be performed.
abstract void	AbstractMongoCollection.explainAsync(Callback<Document> results, Find query) Explains the way that the document will be performed.
void	MongoCollectionImpl.explainAsync(Callback<Document> results, Find query) Explains the way that the document will be performed.
void	AbstractMongoCollection.findAndModifyAsync(Callback<Document> results, FindAndModify.Builder command) Invokes a findAndModify command on the server.
abstract void	AbstractMongoCollection.findAndModifyAsync(Callback<Document> results, FindAndModify command) Invokes a findAndModify command on the server.
void	MongoCollectionImpl.findAndModifyAsync(Callback<Document> results, FindAndModify command) Invokes a findAndModify command on the server.
void	AbstractMongoCollection.findAsync(Callback<MongoIterator<Document>> results, DocumentAssignable query) Finds the set of documents matching the query document in the collection.
void	AbstractMongoCollection.findAsync(Callback<MongoIterator<Document>> results, Find.Builder query) Finds the set of documents matching the query in the collection.
abstract void	AbstractMongoCollection.findAsync(Callback<MongoIterator<Document>> results, Find query) Finds the set of documents matching the query in the collection.
void	MongoCollectionImpl.findAsync(Callback<MongoIterator<Document>> results, Find query) Finds the set of documents matching the query in the collection.
void	AbstractMongoCollection.findOneAsync(Callback<Document> results, DocumentAssignable query) Finds a single matching document in the collection.
void	AbstractMongoCollection.findOneAsync(Callback<Document> results, Find.Builder query) Finds a single matching document in the collection.
abstract void	AbstractMongoCollection.findOneAsync(Callback<Document> results, Find query) Finds a single matching document in the collection.
void	MongoCollectionImpl.findOneAsync(Callback<Document> results, Find query) Finds a single matching document in the collection.
void	AbstractMongoCollection.groupByAsync(Callback<ArrayElement> results, GroupBy.Builder command) Invokes a group command on the server.
abstract void	AbstractMongoCollection.groupByAsync(Callback<ArrayElement> results, GroupBy command) Invokes a group command on the server.
void	MongoCollectionImpl.groupByAsync(Callback<ArrayElement> results, GroupBy command) Invokes a group command on the server.
void	AbstractMongoCollection.insertAsync(Callback<Integer> results, boolean continueOnError, DocumentAssignable... documents) Inserts a set of documents into the collection.
abstract void	AbstractMongoCollection.insertAsync(Callback<Integer> results, boolean continueOnError, Durability durability, DocumentAssignable... documents) Inserts a set of documents into the collection.
void	MongoCollectionImpl.insertAsync(Callback<Integer> results, boolean continueOnError, Durability durability, DocumentAssignable... documents) Inserts a set of documents into the collection.
void	AbstractMongoCollection.insertAsync(Callback<Integer> results, DocumentAssignable... documents) Inserts a set of documents into the collection.
void	AbstractMongoCollection.insertAsync(Callback<Integer> results, Durability durability, DocumentAssignable... documents) Inserts a set of documents into the collection.
void	AbstractMongoCollection.mapReduceAsync(Callback<List<Document>> results, MapReduce.Builder command) Invokes a mapReduce command on the server.
abstract void	AbstractMongoCollection.mapReduceAsync(Callback<List<Document>> results, MapReduce command) Invokes a mapReduce command on the server.
void	MongoCollectionImpl.mapReduceAsync(Callback<List<Document>> results, MapReduce command) Invokes a mapReduce command on the server.
void	MongoDatabaseImpl.runCommandAsync(Callback<Document> reply, String command) Runs a command against the database.
void	MongoDatabaseImpl.runCommandAsync(Callback<Document> reply, String command, DocumentAssignable options) Runs a command against the database.
void	MongoDatabaseImpl.runCommandAsync(Callback<Document> reply, String commandName, int commandValue, DocumentAssignable options) Runs a command against the database.
void	MongoDatabaseImpl.runCommandAsync(Callback<Document> reply, String commandName, String commandValue, DocumentAssignable options) Runs a command against the database.
void	AbstractMongoCollection.saveAsync(Callback<Integer> results, DocumentAssignable document) Saves the document to the collection.
abstract void	AbstractMongoCollection.saveAsync(Callback<Integer> results, DocumentAssignable document, Durability durability) Saves the document to the collection.
void	MongoCollectionImpl.saveAsync(Callback<Integer> results, DocumentAssignable document, Durability durability) Saves the document to the collection.
String	Client.send(Message message, Callback<Reply> replyCallback) Sends a message on the connection.
String	AbstractClient.send(Message message, Callback<Reply> replyCallback) Sends a message on the connection.
String	Client.send(Message message1, Message message2, Callback<Reply> replyCallback) Sends a message on the connection.
String	AbstractClient.send(Message message1, Message message2, Callback<Reply> replyCallback) Sends a message on the connection.
MongoCursorControl	AbstractMongoCollection.streamingFind(Callback<Document> results, DocumentAssignable query) Deprecated.
MongoCursorControl	AbstractMongoCollection.streamingFind(Callback<Document> results, Find query) Deprecated.
void	AbstractMongoCollection.textSearchAsync(Callback<List<TextResult>> results, Text.Builder command) Invokes a text command on the server.
abstract void	AbstractMongoCollection.textSearchAsync(Callback<List<TextResult>> results, Text command) Invokes a text command on the server.
void	MongoCollectionImpl.textSearchAsync(Callback<List<TextResult>> results, Text command) Invokes a text command on the server.
void	AbstractMongoCollection.updateAsync(Callback<Long> results, DocumentAssignable query, DocumentAssignable update) Applies updates to a set of documents within the collection.
void	AbstractMongoCollection.updateAsync(Callback<Long> results, DocumentAssignable query, DocumentAssignable update, boolean multiUpdate, boolean upsert) Applies updates to a set of documents within the collection.
abstract void	AbstractMongoCollection.updateAsync(Callback<Long> results, DocumentAssignable query, DocumentAssignable update, boolean multiUpdate, boolean upsert, Durability durability) Applies updates to a set of documents within the collection.
void	MongoCollectionImpl.updateAsync(Callback<Long> results, DocumentAssignable query, DocumentAssignable update, boolean multiUpdate, boolean upsert, Durability durability) Applies updates to a set of documents within the collection.
void	AbstractMongoCollection.updateAsync(Callback<Long> results, DocumentAssignable query, DocumentAssignable update, Durability durability) Applies updates to a set of documents within the collection.

Constructors in com.allanbank.mongodb.client with parameters of type Callback

Constructor and Description
AbstractReplyCallback(Callback<F> forwardCallback) Create a new AbstractReplyCallback.
LongToIntCallback(Callback<Integer> delegate) Creates a new LongToIntCallback.
ReplyResultCallback(Callback<List<Document>> forwardCallback) Create a new ReplyResultCallback.
ReplyResultCallback(String field, Callback<List<Document>> forwardCallback) Create a new ReplyResultCallback.
TextCallback(Callback<List<TextResult>> delegate) Creates a new TextCallback.

Uses of Callback in com.allanbank.mongodb.connection

Classes in com.allanbank.mongodb.connection that implement Callback

Modifier and Type	Class and Description
class	FutureCallback<V> Implementation of a Callback and Future interfaces.

Methods in com.allanbank.mongodb.connection with parameters of type Callback

Modifier and Type	Method and Description
String	Connection.send(Message message, Callback<Reply> replyCallback) Sends a message on the connection.
String	Connection.send(Message message1, Message message2, Callback<Reply> replyCallback) Sends a message on the connection.

Uses of Callback in com.allanbank.mongodb.connection.auth

Methods in com.allanbank.mongodb.connection.auth with parameters of type Callback

Modifier and Type	Method and Description
String	AuthenticatingConnection.send(Message message, Callback<Reply> replyCallback) Sends a message on the connection.
String	AuthenticatingConnection.send(Message message1, Message message2, Callback<Reply> replyCallback) Sends a message on the connection.

Uses of Callback in com.allanbank.mongodb.connection.message

Methods in com.allanbank.mongodb.connection.message that return Callback

Modifier and Type	Method and Description
Callback<Reply>	PendingMessage.getReplyCallback() Returns the callback for the reply to the message.

Methods in com.allanbank.mongodb.connection.message with parameters of type Callback

Modifier and Type	Method and Description
void	PendingMessageQueue.put(Message message, Callback<Reply> replyCallback) Puts a message onto the queue.
void	PendingMessageQueue.put(Message message, Callback<Reply> replyCallback, Message message2, Callback<Reply> replyCallback2) Puts two messages onto the queue.
void	PendingMessageQueue.put(Message message, Callback<Reply> replyCallback, Message message2, Callback<Reply> replyCallback2) Puts two messages onto the queue.
static void	ReplyHandler.raiseError(Throwable exception, Callback<Reply> replyCallback, Executor executor) Raise an error on the callback, if any.
static void	ReplyHandler.reply(Reply reply, Callback<Reply> replyCallback, Executor executor) Updates to set the reply for the callback, if any.
void	PendingMessage.set(int messageId, Message message, Callback<Reply> replyCallback) Sets the state of the pending message.

Constructors in com.allanbank.mongodb.connection.message with parameters of type Callback

Constructor and Description
PendingMessage(int messageId, Message message, Callback<Reply> replyCallback) Create a new PendingMessage.
ReplyHandler(Callback<Reply> replyCallback, Reply reply) Creates a new ReplyHandler.
ReplyHandler(Callback<Reply> replyCallback, Throwable exception) Creates a new ReplyHandler.

Uses of Callback in com.allanbank.mongodb.connection.proxy

Methods in com.allanbank.mongodb.connection.proxy with parameters of type Callback

Modifier and Type	Method and Description
String	AbstractProxyConnection.send(Message message, Callback<Reply> replyCallback) Sends a message on the connection.
String	AbstractProxyConnection.send(Message message1, Message message2, Callback<Reply> replyCallback) Sends a message on the connection.

Uses of Callback in com.allanbank.mongodb.connection.rs

Methods in com.allanbank.mongodb.connection.rs with parameters of type Callback

Modifier and Type	Method and Description
protected String	ReplicaSetConnection.doSend(Connection conn, Message message1, Message message2, Callback<Reply> reply) Sends the message on the connection.
String	ReplicaSetConnection.send(Message message, Callback<Reply> replyCallback) Sends a message on the connection.
String	ReplicaSetConnection.send(Message message1, Message message2, Callback<Reply> replyCallback) Sends a message on the connection.
protected String	ReplicaSetConnection.trySend(List<ServerState> servers, Message message1, Message message2, Callback<Reply> reply) Tries to send the messages to the first server with either an open connection or that we can open a connection to.
protected String	ReplicaSetConnection.trySendToOpenConnection(List<ServerState> servers, Message message1, Message message2, Callback<Reply> reply) Tries to send the messages to the first server with an open connection.

Uses of Callback in com.allanbank.mongodb.connection.socket

Classes in com.allanbank.mongodb.connection.socket that implement Callback

Modifier and Type	Class and Description
protected static class	SocketConnection.NoopCallback NoopCallback provides a callback that does not look at the reply.

Methods in com.allanbank.mongodb.connection.socket with parameters of type Callback

Modifier and Type	Method and Description
protected void	SocketConnection.raiseError(Throwable exception, Callback<Reply> replyCallback) Updates to raise an error on the callback, if any.
protected void	SocketConnection.reply(Reply reply, Callback<Reply> replyCallback) Updates to set the reply for the callback, if any.
String	SocketConnection.send(Message message, Callback<Reply> replyCallback) Sends a message on the connection.
String	SocketConnection.send(Message message1, Message message2, Callback<Reply> replyCallback) Sends a message on the connection.

Uses of Callback in com.allanbank.mongodb.connection.state

Classes in com.allanbank.mongodb.connection.state that implement Callback

Modifier and Type	Class and Description
class	SecondsBehindCallback SecondsBehindCallback provides a special callback to measure the number of seconds a replica is behind the primary.
class	ServerLatencyCallback ServerLatencyCallback provides a special callback to measure the latency of requests to a server.